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

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

public class FederationUpstream
extends AbstractFederationStream

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.server.federation.AbstractFederationStream

connection, federatedAddressMap, federatedQueueMap, federation, name, server

Constructor Summary

Constructors

Constructor and Description
FederationUpstream(ActiveMQServer server, Federation federation, String name, FederationUpstreamConfiguration config)

Method Summary

Modifier and Type	Method and Description
boolean	deploy(FederationAddressPolicyConfiguration federatedAddressConfig)
boolean	deploy(FederationQueuePolicyConfiguration federatedQueueConfig)
void	deploy(Set<String> policyRefsToDeploy, Map<String,FederationPolicy> policyMap)
FederationUpstreamConfiguration	getConfig()
void	start()
void	stop()

Methods inherited from class org.apache.activemq.artemis.core.server.federation.AbstractFederationStream

callFederationStreamStartedPlugins, callFederationStreamStoppedPlugins, getConnection, getFederation, getName, getPassword, getPriorityAdjustment, getUser

Methods inherited from class java.lang.Object

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

Constructor Detail

FederationUpstream

public FederationUpstream(ActiveMQServer server,
                          Federation federation,
                          String name,
                          FederationUpstreamConfiguration config)

Method Detail

start

public void start()

Specified by:

start in interface FederationStream

Overrides:

start in class AbstractFederationStream

stop

public void stop()

Specified by:

stop in interface FederationStream

Overrides:

stop in class AbstractFederationStream

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

public FederationUpstreamConfiguration getConfig()

Specified by:

getConfig in interface FederationStream

Overrides:

getConfig in class AbstractFederationStream