Class AbstractFederationStream
java.lang.Object
org.apache.activemq.artemis.core.server.federation.AbstractFederationStream
- All Implemented Interfaces:
FederationStream
- Direct Known Subclasses:
FederationDownstream,FederationUpstream
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final FederationConnectionprotected Map<String,FederatedAddress> protected Map<String,FederatedQueue> protected final Federationprotected final SimpleStringprotected final ActiveMQServer -
Constructor Summary
ConstructorsConstructorDescriptionAbstractFederationStream(ActiveMQServer server, Federation federation, String name, FederationStreamConfiguration config) AbstractFederationStream(ActiveMQServer server, Federation federation, String name, FederationStreamConfiguration config, FederationConnection connection) -
Method Summary
-
Field Details
-
server
-
federation
-
name
-
connection
-
federatedQueueMap
-
federatedAddressMap
-
-
Constructor Details
-
AbstractFederationStream
public AbstractFederationStream(ActiveMQServer server, Federation federation, String name, FederationStreamConfiguration config) -
AbstractFederationStream
public AbstractFederationStream(ActiveMQServer server, Federation federation, String name, FederationStreamConfiguration config, FederationConnection connection)
-
-
Method Details
-
start
public void start()- Specified by:
startin interfaceFederationStream
-
stop
public void stop()- Specified by:
stopin interfaceFederationStream
-
getFederation
- Specified by:
getFederationin interfaceFederationStream
-
getConfig
- Specified by:
getConfigin interfaceFederationStream
-
getName
- Specified by:
getNamein interfaceFederationStream
-
getConnection
- Specified by:
getConnectionin interfaceFederationStream
-
getUser
- Specified by:
getUserin interfaceFederationStream
-
getPassword
- Specified by:
getPasswordin interfaceFederationStream
-
getPriorityAdjustment
public int getPriorityAdjustment()- Specified by:
getPriorityAdjustmentin interfaceFederationStream
-
callFederationStreamStartedPlugins
protected void callFederationStreamStartedPlugins() -
callFederationStreamStoppedPlugins
protected void callFederationStreamStoppedPlugins()
-