Uses of Class
org.apache.activemq.artemis.protocol.amqp.connect.federation.AMQPFederation

Packages that use AMQPFederation

Package	Description
org.apache.activemq.artemis.protocol.amqp.connect.federation

Uses of AMQPFederation in org.apache.activemq.artemis.protocol.amqp.connect.federation

Subclasses of AMQPFederation in org.apache.activemq.artemis.protocol.amqp.connect.federation

Modifier and Type	Class	Description
class	AMQPFederationSource	This is the initiating side of a broker federation that occurs over an AMQP broker connection.
class	AMQPFederationTarget	This is the receiving side of an AMQP broker federation that occurs over an inbound connection from a remote peer.

Fields in org.apache.activemq.artemis.protocol.amqp.connect.federation declared as AMQPFederation

Modifier and Type	Field	Description
protected final AMQPFederation	AMQPFederationConsumer.federation
protected final AMQPFederation	AMQPFederationConsumerManager.federation
protected final AMQPFederation	AMQPFederationPolicyManager.federation
protected final AMQPFederation	AMQPFederationSenderController.federation

Methods in org.apache.activemq.artemis.protocol.amqp.connect.federation that return AMQPFederation

Modifier and Type	Method	Description
AMQPFederation	AMQPFederation.addAddressMatchPolicy(FederationReceiveFromAddressPolicy addressPolicy)	Adds a new FederationReceiveFromAddressPolicy entry to the set of policies that this federation will use to create demand on the remote when local demand is present.
AMQPFederation	AMQPFederation.addLinkClosedInterceptor(String id, Predicate<org.apache.qpid.proton.engine.Link> interceptor)	Adds a remote linked closed event interceptor that can intercept the closed event and if it returns true indicate that the close has been handled and that no further action need to be taken for this event.
AMQPFederation	AMQPFederation.addQueueMatchPolicy(FederationReceiveFromQueuePolicy queuePolicy)	Adds a new FederationReceiveFromQueuePolicy entry to the set of policies that this federation will use to create demand on the remote when local demand is present.
final AMQPFederation	AMQPFederationConsumer.getFederation()
AMQPFederation	AMQPFederationPolicyManager.getFederation()	Returns the AMQPFederation instance that owns this policy manager.
final AMQPFederation	AMQPFederationSenderController.getFederation()
AMQPFederation	AMQPFederation.removeLinkClosedInterceptor(String id)	Remove a previously registered link close interceptor from the list of close interceptor bindings.

Constructors in org.apache.activemq.artemis.protocol.amqp.connect.federation with parameters of type AMQPFederation

Modifier	Constructor	Description
	AMQPFederationAddressPolicyManager(AMQPFederation federation, AMQPFederationMetrics metrics, FederationReceiveFromAddressPolicy addressPolicy)
	AMQPFederationEventDispatcher(AMQPFederation federation, AMQPSessionCallback session, org.apache.qpid.proton.engine.Sender sender)
	AMQPFederationEventProcessor(AMQPFederation federation, AMQPSessionContext session, org.apache.qpid.proton.engine.Receiver receiver)	Create the new federation event receiver
	AMQPFederationLocalPolicyManager(AMQPFederation federation, AMQPFederationMetrics metrics, FederationReceiveFromResourcePolicy policy)
	AMQPFederationPolicyManager(AMQPFederation federation, AMQPFederationMetrics metrics, String policyName, FederationType policyType)
	AMQPFederationQueuePolicyManager(AMQPFederation federation, AMQPFederationMetrics metrics, FederationReceiveFromQueuePolicy queuePolicy)
	AMQPFederationRemoteAddressPolicyManager(AMQPFederation federation, AMQPFederationMetrics metrics, String policyName)
	AMQPFederationRemotePolicyManager(AMQPFederation federation, AMQPFederationMetrics metrics, String policyName, FederationType policyType)	Create the remote policy manager instance with the given configuration.
	AMQPFederationRemoteQueuePolicyManager(AMQPFederation federation, AMQPFederationMetrics metrics, String policyName)