Class AMQPBridgeToQueueSender
java.lang.Object
org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgeSender
org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgeToQueueSender
- All Implemented Interfaces:
Closeable, AutoCloseable
Sender type that handles sending messages sent to a local queue to a remote AMQP peer.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic class -
Field Summary
Fields inherited from class AMQPBridgeSender
bridgeManager, closed, configuration, connection, initialized, LINK_SEQUENCE_ID, metrics, policy, policyManager, protonSender, remoteCloseHandler, remoteOpenHandler, senderContext, senderInfo, session -
Constructor Summary
ConstructorsConstructorDescriptionAMQPBridgeToQueueSender(AMQPBridgeToPolicyManager policyManager, AMQPBridgeSenderConfiguration configuration, AMQPSessionContext session, AMQPBridgeSenderInfo senderInfo, AMQPBridgeMetrics.SenderMetrics metrics) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidHandles the create of the actual AMQP sender link on the connection thread.Returns the policy that this sender was configured to use.
-
Constructor Details
-
AMQPBridgeToQueueSender
public AMQPBridgeToQueueSender(AMQPBridgeToPolicyManager policyManager, AMQPBridgeSenderConfiguration configuration, AMQPSessionContext session, AMQPBridgeSenderInfo senderInfo, AMQPBridgeMetrics.SenderMetrics metrics)
-
-
Method Details
-
getPolicy
Description copied from class:AMQPBridgeSenderReturns the policy that this sender was configured to use.- Overrides:
getPolicyin classAMQPBridgeSender- Returns:
- the policy that this sender was configured to use
-
doCreateSender
protected void doCreateSender()Description copied from class:AMQPBridgeSenderHandles the create of the actual AMQP sender link on the connection thread.- Specified by:
doCreateSenderin classAMQPBridgeSender
-