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

Class FederatedAbstract

java.lang.Object

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

All Implemented Interfaces:

ActiveMQServerBasePlugin

Direct Known Subclasses:

FederatedAddress, FederatedQueue

public abstract class FederatedAbstract
extends Object
implements ActiveMQServerBasePlugin

Field Summary

Fields

Modifier and Type	Field and Description
protected Federation	federation
protected Map<FederatedConsumerKey,FederatedQueueConsumer>	remoteQueueConsumers
protected ActiveMQServer	server
protected FederationUpstream	upstream
protected WildcardConfiguration	wildcardConfiguration

Constructor Summary

Constructors

Constructor and Description
FederatedAbstract(Federation federation, ActiveMQServer server, FederationUpstream upstream)

Method Summary

Modifier and Type	Method and Description
void	createRemoteConsumer(FederatedConsumerKey key, Transformer transformer, FederatedQueueConsumerImpl.ClientSessionCallback callback)
protected Transformer	getTransformer(String transformerRef)
boolean	isStarted()
protected Transformer	mergeTransformers(Transformer left, Transformer right)
void	registered(ActiveMQServer server) The plugin has been registered with the server
void	removeRemoteConsumer(FederatedConsumerKey key)
void	start()
void	stop()
void	unregistered(ActiveMQServer server) The plugin has been unregistered with the server

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerBasePlugin

init

Field Detail

federation

protected final Federation federation

server

protected ActiveMQServer server

upstream

protected FederationUpstream upstream

wildcardConfiguration

protected WildcardConfiguration wildcardConfiguration

remoteQueueConsumers

protected final Map<FederatedConsumerKey,FederatedQueueConsumer> remoteQueueConsumers

Constructor Detail

FederatedAbstract

public FederatedAbstract(Federation federation,
                         ActiveMQServer server,
                         FederationUpstream upstream)

Method Detail

registered

public void registered(ActiveMQServer server)

The plugin has been registered with the server

Specified by:

registered in interface ActiveMQServerBasePlugin

Parameters:

server - The ActiveMQServer the plugin has been registered to

unregistered

public void unregistered(ActiveMQServer server)

The plugin has been unregistered with the server

Specified by:

unregistered in interface ActiveMQServerBasePlugin

Parameters:

server - The ActiveMQServer the plugin has been unregistered to

stop

public void stop()

start

public void start()

isStarted

public boolean isStarted()

mergeTransformers

protected Transformer mergeTransformers(Transformer left,
                                        Transformer right)

getTransformer

protected Transformer getTransformer(String transformerRef)

createRemoteConsumer

public void createRemoteConsumer(FederatedConsumerKey key,
                                 Transformer transformer,
                                 FederatedQueueConsumerImpl.ClientSessionCallback callback)

removeRemoteConsumer

public void removeRemoteConsumer(FederatedConsumerKey key)