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

public class AMQPBridgeToQueueSender
extends AMQPBridgeSender

Sender type that handles sending messages sent to a local queue to a remote AMQP peer.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AMQPBridgeToQueueSender.AMQPBridgeToQueueSenderController

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

Constructors

Constructor	Description
AMQPBridgeToQueueSender(AMQPBridgeToPolicyManager policyManager, AMQPBridgeSenderConfiguration configuration, AMQPSessionContext session, AMQPBridgeSenderInfo senderInfo, AMQPBridgeMetrics.SenderMetrics metrics)

Method Summary

Modifier and Type	Method	Description
protected void	doCreateSender()	Handles the create of the actual AMQP sender link on the connection thread.
AMQPBridgeQueuePolicy	getPolicy()	Returns the policy that this sender was configured to use.

Methods inherited from class AMQPBridgeSender

close, getBridgeManager, getConfiguration, getPolicyManager, getRemoteTerminusCapabilities, getSenderInfo, initialize, isClosed, isInitialized, remoteLinkClosedInterceptor, setRemoteClosedHandler, setRemoteOpenHandler

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AMQPBridgeToQueueSender

public AMQPBridgeToQueueSender(AMQPBridgeToPolicyManager policyManager,
 AMQPBridgeSenderConfiguration configuration,
 AMQPSessionContext session,
 AMQPBridgeSenderInfo senderInfo,
 AMQPBridgeMetrics.SenderMetrics metrics)

Method Details

getPolicy

public AMQPBridgeQueuePolicy getPolicy()

Description copied from class: AMQPBridgeSender

Returns the policy that this sender was configured to use.

Overrides:

getPolicy in class AMQPBridgeSender

Returns:

the policy that this sender was configured to use

doCreateSender

protected void doCreateSender()

Description copied from class: AMQPBridgeSender

Handles the create of the actual AMQP sender link on the connection thread.

Specified by:

doCreateSender in class AMQPBridgeSender