org.apache.activemq.artemis.core.server.federation.queue

Class FederatedQueue

java.lang.Object

org.apache.activemq.artemis.core.server.federation.FederatedAbstract

org.apache.activemq.artemis.core.server.federation.queue.FederatedQueue

All Implemented Interfaces:

Serializable, ActiveMQServerBasePlugin, ActiveMQServerConsumerPlugin

public class FederatedQueue
extends FederatedAbstract
implements ActiveMQServerConsumerPlugin, Serializable

Federated Queue, connect to upstream queues routing them to the local queue when a local consumer exist. By default we connect to -1 the current consumer priority on the remote broker, so that if consumers also exist on the remote broker they a dispatched to first. This though is configurable to change this behaviour.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FederatedQueue.Matcher

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.server.federation.FederatedAbstract

federation, remoteQueueConsumers, server, upstream, wildcardConfiguration

Constructor Summary

Constructors

Constructor and Description
FederatedQueue(Federation federation, FederationQueuePolicyConfiguration config, ActiveMQServer server, FederationUpstream federationUpstream)

Method Summary

Modifier and Type	Method and Description
void	afterCreateConsumer(ServerConsumer consumer) After a consumer has been created
void	beforeCloseConsumer(ServerConsumer consumer, boolean failed) Before a consumer is closed
FederationQueuePolicyConfiguration	getConfig()
void	start()

Methods inherited from class org.apache.activemq.artemis.core.server.federation.FederatedAbstract

createRemoteConsumer, getTransformer, isStarted, mergeTransformers, registered, removeRemoteConsumer, stop, unregistered

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerConsumerPlugin

afterCloseConsumer, beforeCreateConsumer, beforeCreateConsumer

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerBasePlugin

init, registered, unregistered

Constructor Detail

FederatedQueue

public FederatedQueue(Federation federation,
                      FederationQueuePolicyConfiguration config,
                      ActiveMQServer server,
                      FederationUpstream federationUpstream)
               throws ActiveMQException

Throws:

ActiveMQException

Method Detail

start

public void start()

Overrides:

start in class FederatedAbstract

afterCreateConsumer

public void afterCreateConsumer(ServerConsumer consumer)

After a consumer has been created

Specified by:

afterCreateConsumer in interface ActiveMQServerConsumerPlugin

Parameters:

consumer - the created consumer

getConfig

public FederationQueuePolicyConfiguration getConfig()

beforeCloseConsumer

public void beforeCloseConsumer(ServerConsumer consumer,
                                boolean failed)

Before a consumer is closed

Specified by:

beforeCloseConsumer in interface ActiveMQServerConsumerPlugin

Parameters:

consumer -

failed -