Uses of Interface
org.apache.activemq.artemis.protocol.amqp.federation.FederationConsumer

Packages that use FederationConsumer

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

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

Classes in org.apache.activemq.artemis.protocol.amqp.connect.federation that implement FederationConsumer

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.
class	AMQPFederationConsumer	Base class for AMQP Federation consumers that implements some of the common functionality.
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.

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

Modifier and Type	Method	Description
default void	ActiveMQServerAMQPFederationPlugin.afterCloseFederationConsumer(FederationConsumer consumer)	After a consumer for a federated resource is closed
default void	ActiveMQServerAMQPFederationPlugin.afterCreateFederationConsumer(FederationConsumer consumer)	After a consumer for a federated resource is created
default void	ActiveMQServerAMQPFederationPlugin.afterFederationConsumerMessageHandled(FederationConsumer consumer, Message message)	After a federation consumer handles a message
default void	ActiveMQServerAMQPFederationPlugin.beforeCloseFederationConsumer(FederationConsumer consumer)	Before a consumer for a federated resource is closed
default void	ActiveMQServerAMQPFederationPlugin.beforeFederationConsumerMessageHandled(FederationConsumer consumer, Message message)	Before a federation consumer handles a message
protected final void	AMQPFederationLocalPolicyManager.signalPluginAfterCloseFederationConsumer(FederationConsumer consumer)	Signal any registered plugins for this federation instance that a remote consumer has now been closed.
protected final void	AMQPFederationLocalPolicyManager.signalPluginAfterCreateFederationConsumer(FederationConsumer consumer)	Signal any registered plugins for this federation instance that a remote consumer has been created.
protected final void	AMQPFederationLocalPolicyManager.signalPluginBeforeCloseFederationConsumer(FederationConsumer consumer)	Signal any registered plugins for this federation instance that a remote consumer is about to be closed.