public class FederatedQueue extends FederatedAbstract implements ActiveMQServerConsumerPlugin, Serializable
| Modifier and Type | Class and Description |
|---|---|
static class |
FederatedQueue.Matcher |
federation, remoteQueueConsumers, server, upstream, wildcardConfiguration| Constructor and Description |
|---|
FederatedQueue(Federation federation,
FederationQueuePolicyConfiguration config,
ActiveMQServer server,
FederationUpstream federationUpstream) |
| 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() |
createRemoteConsumer, getTransformer, isStarted, mergeTransformers, registered, removeRemoteConsumer, stop, unregisteredclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitafterCloseConsumer, beforeCreateConsumer, beforeCreateConsumerinit, registered, unregisteredpublic FederatedQueue(Federation federation, FederationQueuePolicyConfiguration config, ActiveMQServer server, FederationUpstream federationUpstream) throws ActiveMQException
ActiveMQExceptionpublic void start()
start in class FederatedAbstractpublic void afterCreateConsumer(ServerConsumer consumer)
afterCreateConsumer in interface ActiveMQServerConsumerPluginconsumer - the created consumerpublic FederationQueuePolicyConfiguration getConfig()
public void beforeCloseConsumer(ServerConsumer consumer, boolean failed)
beforeCloseConsumer in interface ActiveMQServerConsumerPluginconsumer - failed - Copyright © 2019 JBoss by Red Hat. All rights reserved.