Package org.apache.activemq.artemis.core.server.federation

Class Federation

java.lang.Object

org.apache.activemq.artemis.core.server.federation.Federation

public class Federation
extends Object

Constructor Summary

Constructors

Constructor	Description
Federation(ActiveMQServer server, FederationConfiguration config)

Method Summary

Modifier and Type	Method	Description
void	deploy()
boolean	deploy(FederationDownstreamConfiguration downstreamConfiguration, Map<String,FederationPolicy> federationPolicyMap)
boolean	deploy(FederationUpstreamConfiguration upstreamConfiguration, Map<String,FederationPolicy> federationPolicyMap)
FederationUpstream	get(String name)
FederationConfiguration	getConfig()
FederationDownstream	getDownstream(String name)
SimpleString	getName()
boolean	isStarted()
void	register(FederatedAbstract federatedAbstract)
void	start()
void	stop()
boolean	undeploy(String name)
void	unregister(FederatedAbstract federatedAbstract)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Federation

public Federation(ActiveMQServer server,
 FederationConfiguration config)

Method Details

start

public void start()
           throws ActiveMQException

Throws:

ActiveMQException

stop

public void stop()

deploy

public void deploy()
            throws ActiveMQException

Throws:

ActiveMQException

isStarted

public boolean isStarted()

undeploy

public boolean undeploy(String name)

deploy

public boolean deploy(FederationUpstreamConfiguration upstreamConfiguration,
 Map<String,FederationPolicy> federationPolicyMap)
               throws ActiveMQException

Throws:

ActiveMQException

deploy

public boolean deploy(FederationDownstreamConfiguration downstreamConfiguration,
 Map<String,FederationPolicy> federationPolicyMap)
               throws ActiveMQException

Throws:

ActiveMQException

get

public FederationUpstream get(String name)

getDownstream

public FederationDownstream getDownstream(String name)

register

public void register(FederatedAbstract federatedAbstract)

unregister

public void unregister(FederatedAbstract federatedAbstract)

getConfig

public FederationConfiguration getConfig()

getName

public SimpleString getName()