Package org.apache.activemq.artemis.protocol.amqp.connect.federation
package org.apache.activemq.artemis.protocol.amqp.connect.federation
-
ClassDescriptionBroker plugin which allows users to intercept federation related events when AMQP federation is configured on the broker.A single AMQP Federation instance that can be tied to an AMQP broker connection or used on a remote peer to control the reverse case of when the remote configures the target side of the connection.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.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.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.The AMQP Federation implementation of an federation address policy manager.SenderControllerused when an AMQP federation Address receiver is created and this side of the connection needs to create a matching sender.AMQPFederationAsyncCompletion type used to implement the handlers for asynchronous calls in AMQP federation types.Capabilities class that provides a reconciliation between what the remote offered as compared to what this federation instance desired in order to determine what features can and cannot be used.ASenderControllerimplementation used by the AMQP federation control link to encode and send federation policies or other commands to the remote side of the AMQP federation instance.A specialized AMQP Receiver that handles commands from a remote Federation connection such as handling incoming policies that should be applied to local addresses and queues.A configuration class that contains API for getting federation specific configuration either from aMapof configuration elements or from the connection associated with the federation instance, or possibly from a set default value.Constants class for values used in the AMQP Federation implementation.Base class for AMQP Federation consumers that implements some of the common functionality.Configuration options applied to a consumer created from federation policies for address or queue federation.Management interface that is backed by an active federation consumer that was created when demand was applied to a matching address or queue.Management object used for AMQP federation address and queue consumers to expose consumer state.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.Management service control interface for an AMQPFederation instance.Sender controller used to fire events from one side of an AMQP Federation connection to the other side.A specialized AMQP Receiver that handles events from a remote Federation connection such as addition of addresses or queues where federation was requested but they did not exist at the time and the federation consumer was rejected.Tools used for sending and receiving events inside AMQP message instance.Information and identification class for Federation consumers created to federate queues and addresses.Management service control interface for an AMQPFederation policy manager instance.Management service control for an AMQP Federation local policy manager instance.A federation policy manager for policies that operate on the local side of this broker connection.Support methods for working with the AMQP Federation management typesA Metrics class that supports nesting to provide various elements in the federation space a view of its own Metrics for federation operations.Metrics for a single consumer instance that will also updates to the parents when the Metrics are updated by the consumer.Metrics for a single producer instance that will also updates to the parents when the Metrics are updated by the producer.Base Federation policy manager that declares some common APIs that address or queue policy managers must provide implementations for.Tools used when loading AMQP Broker connections configuration that includes Federation configuration.Management interface that is backed by an active federation producer that was created when demand was applied to a matching address or queue on the remote broker that is bringing messages to itself via federation.Management object used for AMQP federation address and queue producer to expose producer state.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.The AMQP Federation implementation of an federation queue policy manager.SenderControllerused when an AMQP federation Queue receiver is created and this side of the connection needs to create a matching sender.Policy manager that manages state data for remote AMQP Federation Address policies and their associated senders.Management service control interface for an AMQPFederation policy manager instance that originates from the remote broker.Management service control instance for an AMQPFederation policy manager instance that federates messages from this broker to the opposing side of the broker connection.Represents the remote policy manager that is interacting with this server.Policy manager that manages state data for remote AMQP Federation Queue policies and their associated senders.A base class abstractSenderControllerimplementation for use by federation address and queue senders that provides some common functionality used between both.This is the initiating side of a broker federation that occurs over an AMQP broker connection.Management service control instance for an AMQPFederationSource instance that federates messages from the remote broker on the opposing side of this broker connection.This is the receiving side of an AMQP broker federation that occurs over an inbound connection from a remote peer.Management service control instance for an AMQPFederationTarget instance that is the target of an AMQP broker connection with federation configured.