public class FederatedAddress extends FederatedAbstract implements ActiveMQServerQueuePlugin, Serializable
Modifier and Type | Class and Description |
---|---|
static class |
FederatedAddress.Matcher |
Modifier and Type | Field and Description |
---|---|
static SimpleString |
HDR_HOPS |
federation, remoteQueueConsumers, server, upstream, wildcardConfiguration
Constructor and Description |
---|
FederatedAddress(Federation federation,
FederationAddressPolicyConfiguration config,
ActiveMQServer server,
FederationUpstream upstream) |
Modifier and Type | Method and Description |
---|---|
void |
afterCreateQueue(Queue queue)
After a queue has been created
|
void |
beforeDestroyQueue(Queue queue,
SecurityAuth session,
boolean checkConsumerCount,
boolean removeConsumers,
boolean autoDeleteAddress)
Before an address is removed
|
FederationAddressPolicyConfiguration |
getConfig() |
void |
start() |
createRemoteConsumer, getTransformer, isStarted, mergeTransformers, registered, removeRemoteConsumer, stop, unregistered
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
afterDestroyQueue, beforeCreateQueue, beforeDestroyQueue
init, registered, unregistered
public static final SimpleString HDR_HOPS
public FederatedAddress(Federation federation, FederationAddressPolicyConfiguration config, ActiveMQServer server, FederationUpstream upstream)
public void start()
start
in class FederatedAbstract
public void afterCreateQueue(Queue queue)
afterCreateQueue
in interface ActiveMQServerQueuePlugin
queue
- The newly created queuepublic FederationAddressPolicyConfiguration getConfig()
public void beforeDestroyQueue(Queue queue, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress)
beforeDestroyQueue
in interface ActiveMQServerQueuePlugin
queue
- The queue that will be removedCopyright © 2019 JBoss by Red Hat. All rights reserved.