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

Packages that use AMQPFederationConsumer

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

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

Classes in org.apache.activemq.artemis.protocol.amqp.connect.federation with type parameters of type AMQPFederationConsumer

Modifier and Type	Class	Description
class	AMQPFederationConsumerManager<E, Consumer extends AMQPFederationConsumer>	An abstract base for managing federation consumer instances that holds the demand currently present for a federated resource and the consumer that exists to service that demand.

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

Modifier and Type	Class	Description
final class	AMQPFederationAddressBindingsConsumer	Consumer implementation for Federated Addresses that receives from a remote AMQP peer and forwards those messages onto the internal bindings on a given address that matched criteria of the given FederationConsumerInfo.
final class	AMQPFederationAddressConduitConsumer	Consumer implementation for Federated Addresses that receives from a remote AMQP peer and then routes the messages to the target address for dispatch to all attached bindings.
class	AMQPFederationAddressConsumer	Base AMQP federation address consumer implementation that provides the common functionality that all federation address consumers must provide with extension points to customize the actual message routing behavior as needed.
final class	AMQPFederationQueueConsumer	Consumer implementation for Federated Queues that receives from a remote AMQP peer and forwards those messages onto the internal broker Queue for consumption by an attached resource.

Fields in org.apache.activemq.artemis.protocol.amqp.connect.federation with type parameters of type AMQPFederationConsumer

Modifier and Type	Field	Description
protected Consumer<AMQPFederationConsumer>	AMQPFederationConsumer.remoteCloseHandler
protected Consumer<AMQPFederationConsumer>	AMQPFederationConsumer.remoteOpenHandler

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

Modifier and Type	Method	Description
final AMQPFederationConsumer	AMQPFederationConsumer.setRemoteClosedHandler(Consumer<AMQPFederationConsumer> handler)	Provides and event point for notification of the consumer having been closed by the remote.
final AMQPFederationConsumer	AMQPFederationConsumer.setRemoteOpenHandler(Consumer<AMQPFederationConsumer> handler)	Provides and event point for notification of the receiver having been opened successfully by the remote.

Methods in org.apache.activemq.artemis.protocol.amqp.connect.federation with parameters of type AMQPFederationConsumer

Modifier and Type	Method	Description
static void	AMQPFederationManagementSupport.registerFederationSourceConsumer(String brokerConnectionName, AMQPFederationConsumer consumer)	Registers the federation consumer with the server management services on the source.
static void	AMQPFederationManagementSupport.registerFederationTargetConsumer(String remoteNodeId, String brokerConnectionName, AMQPFederationConsumer consumer)	Registers the federation consumer with the server management services on the target.
protected void	AMQPFederationLocalPolicyManager.tryCloseFederationConsumer(AMQPFederationConsumer federationConsuner)	Attempts to close a federation consumer and signals the installed federation plugin of the impending and post closed state.
static void	AMQPFederationManagementSupport.unregisterFederationSourceConsumer(String brokerConnectionName, AMQPFederationConsumer consumer)	Unregisters the federation consumer with the server management services on the source.
static void	AMQPFederationManagementSupport.unregisterFederationTargetConsumer(String remoteNodeId, String brokerConnectionName, AMQPFederationConsumer consumer)	Unregisters the federation consumer with the server management services on the target.

Method parameters in org.apache.activemq.artemis.protocol.amqp.connect.federation with type arguments of type AMQPFederationConsumer

Modifier and Type	Method	Description
final AMQPFederationConsumer	AMQPFederationConsumer.setRemoteClosedHandler(Consumer<AMQPFederationConsumer> handler)	Provides and event point for notification of the consumer having been closed by the remote.
final AMQPFederationConsumer	AMQPFederationConsumer.setRemoteOpenHandler(Consumer<AMQPFederationConsumer> handler)	Provides and event point for notification of the receiver having been opened successfully by the remote.
final void	AMQPFederationConsumer.startAsync(AMQPFederationAsyncCompletion<AMQPFederationConsumer> completion)	Asynchronously starts a previously stopped federation consumer which should trigger a grant of credit to the remote thereby allowing new incoming messages to be federated.
final void	AMQPFederationConsumer.stopAsync(AMQPFederationAsyncCompletion<AMQPFederationConsumer> completion)	Stops message consumption on this consumer instance but leaves the consumer in a state where it could be restarted by a call to AMQPFederationConsumer.startAsync(AMQPFederationAsyncCompletion) once the consumer enters the stopped state.

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

Modifier	Constructor	Description
	AMQPFederationConsumerControlType(AMQPFederationConsumer consumer)