Package org.apache.activemq.artemis.protocol.amqp.connect.bridge
package org.apache.activemq.artemis.protocol.amqp.connect.bridge
-
ClassDescriptionPolicy used for bridging addresses between peers.An asynchronous completion type used to implement the handlers for asynchronous calls in AMQP bridge types.A configuration class that contains API for getting AMQP bridge specific configuration either from a
Mapof configuration elements or from the connection associated with the bridge instance, or possibly from a set default value.Constants class for values used in the AMQP Bridge implementation.AMQP Bridge policy manager that tracks local addresses that match the policy configurations for local demand and creates receivers to the remote peer.Receiver implementation for Bridged Addresses that receives from a remote AMQP peer and forwards those messages onto the internal broker Address for consumption by an attached consumers.Base class for AMQP bridge policy managers that bridge from the remote peer back to this peer for some configured resource.AMQP Bridge policy manager that tracks local queues that match the policy configurations for local demand and creates consumers to the remote peer configured.Receiver implementation for Bridged Queues that receives from a remote AMQP peer and forwards those messages onto the internal broker Queue for consumption by an attached consumers.Base bridge link configuration that carries configuration common to both sender or receiver bridge links created by the bridge managers.Support methods for working with the AMQP bridge management typesAMQP Bridge manager object that handles starting and stopping bridge operations as needed for the parent broker connection.Management service control interface for an AMQP bridgeManager instance.Management service control instance for an AMQP bridge manager instance that bridges messages to or from the remote peer on the opposing side of this broker connection.Simple AMQP Bridge aggregation tool used to simplify broker connection management of multiple bridgesA Metrics class that supports nesting to provide various elements in the bridge space a view of its own Metrics for bridging operations.Metrics for a single receiver instance that will also updates to the parents when the Metrics are updated by the receiver.Metrics for a single sender instance that will also updates to the parents when the Metrics are updated by the sender.Base class for AMQP bridge sender and receiver policies that configure bridging to or from addresses and queues.Base API for a bridged resource policy manager.Management service control interface for an AMQP bridge policy manager instance.Management service control for an AMQP bridge policy manager instance.Base implementation for AMQP Bridge receiver implementationsConfiguration options applied to a receiver created from bridge from policies for address or queue bridging.Management interface that is backed by an active bridge receiver that was created when demand was applied to a matching address or queue.Management object used for AMQP bridge address and queue receivers to expose receiver state.Information and identification interface for AMQP bridgeManager receivers that will be created on the remote peer as demand on the local broker is detected.An abstract base for managing bridge receiver instances that holds the demand currently present for a bridged resource and the receiver that exists to service that demand.Base implementation for AMQP Bridge sender implementationsConfiguration options applied to a sender created from bridge from policies for address or queue bridging.Management interface that is backed by an active bridge sender that was created when demand was applied to a matching address or queue on the remote broker that is bringing messages to itself via bridge.Management object used for AMQP bridge address and queue senders to expose sender state.Information and identification interface for AMQP bridge senders that will be created on the remote peer as demand on the local broker is detected.An abstract base for managing bridge sender instances that manages the existence of a bridge sender both while active and while attempting recovery.Support class for operations involving the AMQP Bridge.AMQP Bridge policy manager that tracks local addresses that match the policy configurations and creates senders to the remote peer for that address until such time as the address is removed locally.Sender type that handles sending messages sent to a local address to a remote AMQP peer.Base class for AMQP bridge policy managers that bridge to the remote peer from this peer for some configured resource.AMQP Bridge policy manager that tracks local queues that match the policy configurations and creates senders to the remote peer for that address until such time as the queue is removed locally.Sender type that handles sending messages sent to a local queue to a remote AMQP peer.A base class abstractSenderControllerimplementation for use by bridge address and queue senders that provides some common functionality used between both.Enumeration that defines the type of AMQP bridging a given policy manager implements