Class AMQPBridgeToAddressSender

java.lang.Object

org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgeSender

org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgeToAddressSender

All Implemented Interfaces:

Closeable, AutoCloseable

public class AMQPBridgeToAddressSender
extends AMQPBridgeSender

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AMQPBridgeToAddressSender.AMQPBridgeToAddressSenderController

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
AMQPBridgeToAddressSender(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.
AMQPBridgeAddressPolicy	getPolicy()	Returns the policy that this sender was configured to use.
AMQPBridgeToAddressPolicyManager	getPolicyManager()	Returns the AMQPBridgeToPolicyManager that this sender operates under.

Methods inherited from class AMQPBridgeSender

close, getBridgeManager, getConfiguration, 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

AMQPBridgeToAddressSender

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

Method Details

getPolicyManager

public AMQPBridgeToAddressPolicyManager getPolicyManager()

Description copied from class: AMQPBridgeSender

Returns the AMQPBridgeToPolicyManager that this sender operates under.

Overrides:

getPolicyManager in class AMQPBridgeSender

Returns:

the AMQPBridgeToPolicyManager that this sender operates under

getPolicy

public AMQPBridgeAddressPolicy 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