public abstract class FederatedAbstract extends Object implements ActiveMQServerBasePlugin
| Modifier and Type | Field and Description |
|---|---|
protected Federation |
federation |
protected Map<FederatedConsumerKey,FederatedQueueConsumer> |
remoteQueueConsumers |
protected ActiveMQServer |
server |
protected FederationUpstream |
upstream |
protected WildcardConfiguration |
wildcardConfiguration |
| Constructor and Description |
|---|
FederatedAbstract(Federation federation,
ActiveMQServer server,
FederationUpstream upstream) |
| Modifier and Type | Method and Description |
|---|---|
void |
createRemoteConsumer(FederatedConsumerKey key,
Transformer transformer,
FederatedQueueConsumer.ClientSessionCallback callback) |
protected Transformer |
getTransformer(String transformerRef) |
boolean |
isStarted() |
protected Transformer |
mergeTransformers(Transformer left,
Transformer right) |
void |
registered(ActiveMQServer server)
The plugin has been registered with the server
|
void |
removeRemoteConsumer(FederatedConsumerKey key) |
void |
start() |
void |
stop() |
void |
unregistered(ActiveMQServer server)
The plugin has been unregistered with the server
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitinitprotected final Federation federation
protected ActiveMQServer server
protected FederationUpstream upstream
protected WildcardConfiguration wildcardConfiguration
protected final Map<FederatedConsumerKey,FederatedQueueConsumer> remoteQueueConsumers
public FederatedAbstract(Federation federation, ActiveMQServer server, FederationUpstream upstream)
public void registered(ActiveMQServer server)
registered in interface ActiveMQServerBasePluginserver - The ActiveMQServer the plugin has been registered topublic void unregistered(ActiveMQServer server)
unregistered in interface ActiveMQServerBasePluginserver - The ActiveMQServer the plugin has been unregistered topublic void stop()
public void start()
public boolean isStarted()
protected Transformer mergeTransformers(Transformer left, Transformer right)
protected Transformer getTransformer(String transformerRef)
public void createRemoteConsumer(FederatedConsumerKey key, Transformer transformer, FederatedQueueConsumer.ClientSessionCallback callback)
public void removeRemoteConsumer(FederatedConsumerKey key)
Copyright © 2019 JBoss by Red Hat. All rights reserved.