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

Class FederatedAddress

java.lang.Object

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

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

All Implemented Interfaces:

Serializable, ActiveMQServerAddressPlugin, ActiveMQServerBasePlugin, ActiveMQServerBindingPlugin

public class FederatedAddress
extends FederatedAbstract
implements ActiveMQServerBindingPlugin, ActiveMQServerAddressPlugin, Serializable

Federated Address, replicate messages from the remote brokers address to itself.

Only when a queue exists on the local broker do we replicate, this is to avoid un-needed replication

All messages are replicated, this is on purpose so should a number queues exist with different filters we dont have have a consumer per queue filter.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FederatedAddress.Matcher

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FEDERATED_QUEUE_PREFIX
static final SimpleString	HDR_HOPS

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

federation, remoteQueueConsumers, server, upstream, wildcardConfiguration

Constructor Summary

Constructors

Constructor	Description
FederatedAddress(Federation federation, FederationAddressPolicyConfiguration config, ActiveMQServer server, FederationUpstream upstream)

Method Summary

Modifier and Type	Method	Description
void	afterAddAddress(AddressInfo addressInfo, boolean reload)	After an address has been added tot he broker
void	afterAddBinding(Binding binding)	After a binding has been added
void	beforeRemoveBinding(SimpleString uniqueName, Transaction tx, boolean deleteData)	Before a binding is removed
FederationAddressPolicyConfiguration	getConfig()
void	start()

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

createRemoteConsumer, getTransformer, isStarted, mergeTransformers, registered, removeRemoteConsumer, stop, unregistered

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.ActiveMQServerAddressPlugin

afterRemoveAddress, afterUpdateAddress, beforeAddAddress, beforeRemoveAddress, beforeUpdateAddress

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

init, registered, setInit, unregistered

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

afterRemoveBinding, beforeAddBinding

Field Details

FEDERATED_QUEUE_PREFIX

public static final String FEDERATED_QUEUE_PREFIX

See Also:

• Constant Field Values

HDR_HOPS

public static final SimpleString HDR_HOPS

Constructor Details

FederatedAddress

public FederatedAddress(Federation federation,
 FederationAddressPolicyConfiguration config,
 ActiveMQServer server,
 FederationUpstream upstream)

Method Details

start

public void start()

Overrides:

start in class FederatedAbstract

afterAddAddress

public void afterAddAddress(AddressInfo addressInfo,
 boolean reload)

Description copied from interface: ActiveMQServerAddressPlugin

After an address has been added tot he broker

Specified by:

afterAddAddress in interface ActiveMQServerAddressPlugin

Parameters:

addressInfo - The newly added address

reload - If the address is being reloaded

afterAddBinding

public void afterAddBinding(Binding binding)

Description copied from interface: ActiveMQServerBindingPlugin

After a binding has been added

Specified by:

afterAddBinding in interface ActiveMQServerBindingPlugin

Parameters:

binding - The newly added binding

beforeRemoveBinding

public void beforeRemoveBinding(SimpleString uniqueName,
 Transaction tx,
 boolean deleteData)

Description copied from interface: ActiveMQServerBindingPlugin

Before a binding is removed

Specified by:

beforeRemoveBinding in interface ActiveMQServerBindingPlugin

getConfig

public FederationAddressPolicyConfiguration getConfig()