Class FederatedAbstract
java.lang.Object
org.apache.activemq.artemis.core.server.federation.FederatedAbstract
- All Implemented Interfaces:
ActiveMQServerBasePlugin
- Direct Known Subclasses:
FederatedAddress,FederatedQueue
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final Federationprotected final Map<FederatedConsumerKey,FederatedQueueConsumer> protected ActiveMQServerprotected FederationUpstreamprotected WildcardConfiguration -
Constructor Summary
ConstructorsConstructorDescriptionFederatedAbstract(Federation federation, ActiveMQServer server, FederationUpstream upstream) -
Method Summary
Modifier and TypeMethodDescriptionvoidcreateRemoteConsumer(FederatedConsumerKey key, Transformer transformer, FederatedQueueConsumerImpl.ClientSessionCallback callback) protected TransformergetTransformer(String transformerRef) booleanprotected TransformermergeTransformers(Transformer left, Transformer right) voidregistered(ActiveMQServer server) The plugin has been registered with the servervoidvoidstart()voidstop()voidunregistered(ActiveMQServer server) The plugin has been unregistered with the serverMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerBasePlugin
init, setInit
-
Field Details
-
federation
-
server
-
upstream
-
wildcardConfiguration
-
remoteQueueConsumers
-
-
Constructor Details
-
FederatedAbstract
-
-
Method Details
-
registered
The plugin has been registered with the server- Specified by:
registeredin interfaceActiveMQServerBasePlugin- Parameters:
server- The ActiveMQServer the plugin has been registered to
-
unregistered
The plugin has been unregistered with the server- Specified by:
unregisteredin interfaceActiveMQServerBasePlugin- Parameters:
server- The ActiveMQServer the plugin has been unregistered to
-
stop
public void stop() -
start
public void start() -
isStarted
public boolean isStarted() -
mergeTransformers
-
getTransformer
-
createRemoteConsumer
public void createRemoteConsumer(FederatedConsumerKey key, Transformer transformer, FederatedQueueConsumerImpl.ClientSessionCallback callback) -
removeRemoteConsumer
-