Uses of Class
org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgeReceiver
Packages that use AMQPBridgeReceiver
-
Uses of AMQPBridgeReceiver in org.apache.activemq.artemis.protocol.amqp.connect.bridge
Modifier and TypeClassDescriptionclassReceiver 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.classReceiver 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.Fields in org.apache.activemq.artemis.protocol.amqp.connect.bridge with type parameters of type AMQPBridgeReceiverModifier and TypeFieldDescriptionprotected Consumer<AMQPBridgeReceiver> AMQPBridgeReceiver.remoteCloseHandlerprotected Consumer<AMQPBridgeReceiver> AMQPBridgeReceiver.remoteOpenHandlerMethods in org.apache.activemq.artemis.protocol.amqp.connect.bridge that return AMQPBridgeReceiverModifier and TypeMethodDescriptionprotected abstract AMQPBridgeReceiverAMQPBridgeReceiverManager.createBridgeReceiver()Creates a new bridge receiver that this manager will monitor and maintain.final AMQPBridgeReceiverAMQPBridgeReceiver.setRemoteClosedHandler(Consumer<AMQPBridgeReceiver> handler) Provides and event point for notification of the receiver having been closed by the remote.final AMQPBridgeReceiverAMQPBridgeReceiver.setRemoteOpenHandler(Consumer<AMQPBridgeReceiver> 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.bridge with parameters of type AMQPBridgeReceiverModifier and TypeMethodDescriptionstatic voidAMQPBridgeManagementSupport.registerBridgeReceiver(AMQPBridgeReceiver receiver) Registers the bridge receiver with the server management services on the source.protected voidAMQPBridgeFromPolicyManager.tryCloseBridgeReceiver(AMQPBridgeReceiver bridgeReceiver) Attempts to close a bridge receiver.static voidAMQPBridgeManagementSupport.unregisterBridgeReceiver(AMQPBridgeReceiver receiver) Unregisters the bridge receiver with the server management services on the source.Method parameters in org.apache.activemq.artemis.protocol.amqp.connect.bridge with type arguments of type AMQPBridgeReceiverModifier and TypeMethodDescriptionfinal AMQPBridgeReceiverAMQPBridgeReceiver.setRemoteClosedHandler(Consumer<AMQPBridgeReceiver> handler) Provides and event point for notification of the receiver having been closed by the remote.final AMQPBridgeReceiverAMQPBridgeReceiver.setRemoteOpenHandler(Consumer<AMQPBridgeReceiver> handler) Provides and event point for notification of the receiver having been opened successfully by the remote.final voidAMQPBridgeReceiver.startAsync(AMQPBridgeAsyncCompletion<AMQPBridgeReceiver> completion) Asynchronously starts a previously stopped bridgeManager receiver which should trigger a grant of credit to the remote thereby allowing new incoming messages to be bridged.final voidAMQPBridgeReceiver.stopAsync(AMQPBridgeAsyncCompletion<AMQPBridgeReceiver> completion) Stops message consumption on this receiver instance but leaves the receiver in a state where it could be restarted by a call toAMQPBridgeReceiver.startAsync(AMQPBridgeAsyncCompletion)once the receiver enters the stopped state.Constructors in org.apache.activemq.artemis.protocol.amqp.connect.bridge with parameters of type AMQPBridgeReceiver