Uses of Package
org.apache.activemq.artemis.protocol.amqp.connect.federation
Packages that use org.apache.activemq.artemis.protocol.amqp.connect.federation
Package
Description
-
Classes in org.apache.activemq.artemis.protocol.amqp.connect.federation used by org.apache.activemq.artemis.protocol.amqp.connectClassDescriptionThis is the receiving side of an AMQP broker federation that occurs over an inbound connection from a remote peer.
-
Classes in org.apache.activemq.artemis.protocol.amqp.connect.federation used by org.apache.activemq.artemis.protocol.amqp.connect.federationClassDescriptionA 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.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.Wrapper around the standard receiver context that provides federation specific entry points and customizes inbound delivery handling for this Address receiver.The AMQP Federation implementation of an federation address policy manager.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.A configuration class that contains API for getting federation specific configuration either from a
Mapof configuration elements or from the connection associated with the federation instance, or possibly from a set default value.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 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.Information and identification class for Federation consumers created to federate queues and addresses.Management service control interface for an AMQPFederation policy manager instance.A federation policy manager for policies that operate on the local side of this broker connection.A 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.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.The AMQP Federation implementation of an federation queue policy manager.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.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.This is the receiving side of an AMQP broker federation that occurs over an inbound connection from a remote peer.