Class FederationUpstream
java.lang.Object
org.apache.activemq.artemis.core.server.federation.AbstractFederationStream
org.apache.activemq.artemis.core.server.federation.FederationUpstream
- All Implemented Interfaces:
FederationStream
-
Field Summary
Fields inherited from class org.apache.activemq.artemis.core.server.federation.AbstractFederationStream
connection, federatedAddressMap, federatedQueueMap, federation, name, server -
Constructor Summary
ConstructorsConstructorDescriptionFederationUpstream(ActiveMQServer server, Federation federation, String name, FederationUpstreamConfiguration config) -
Method Summary
Modifier and TypeMethodDescriptionvoidbooleandeploy(FederationAddressPolicyConfiguration federatedAddressConfig) booleandeploy(FederationQueuePolicyConfiguration federatedQueueConfig) voidstart()voidstop()Methods inherited from class org.apache.activemq.artemis.core.server.federation.AbstractFederationStream
callFederationStreamStartedPlugins, callFederationStreamStoppedPlugins, getConnection, getFederation, getName, getPassword, getPriorityAdjustment, getUser
-
Constructor Details
-
FederationUpstream
public FederationUpstream(ActiveMQServer server, Federation federation, String name, FederationUpstreamConfiguration config)
-
-
Method Details
-
start
public void start()- Specified by:
startin interfaceFederationStream- Overrides:
startin classAbstractFederationStream
-
stop
public void stop()- Specified by:
stopin interfaceFederationStream- Overrides:
stopin classAbstractFederationStream
-
deploy
public void deploy(Set<String> policyRefsToDeploy, Map<String, FederationPolicy> policyMap) throws ActiveMQException- Throws:
ActiveMQException
-
deploy
public boolean deploy(FederationQueuePolicyConfiguration federatedQueueConfig) throws ActiveMQException - Throws:
ActiveMQException
-
deploy
public boolean deploy(FederationAddressPolicyConfiguration federatedAddressConfig) throws ActiveMQException - Throws:
ActiveMQException
-
getConfig
- Specified by:
getConfigin interfaceFederationStream- Overrides:
getConfigin classAbstractFederationStream
-