Package 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	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	Description
FederatedQueue(Federation federation, FederationQueuePolicyConfiguration config, ActiveMQServer server, FederationUpstream federationUpstream)

Method Summary

Modifier and Type	Method	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.ActiveMQServerBasePlugin

init, registered, setInit, unregistered

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

afterCloseConsumer, beforeCreateConsumer, beforeCreateConsumer

Constructor Details

FederatedQueue

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

Throws:

ActiveMQException

Method Details

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