Class AMQPBridgeToAddressSender.AMQPBridgeToAddressSenderController

java.lang.Object

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

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

All Implemented Interfaces:

SenderController

Enclosing class:

AMQPBridgeToAddressSender

public static class AMQPBridgeToAddressSender.AMQPBridgeToAddressSenderController
extends AMQPBridgeToSenderController

Nested Class Summary

Nested classes/interfaces inherited from class AMQPBridgeToSenderController

AMQPBridgeToSenderController.SenderRole

Nested classes/interfaces inherited from interface SenderController

SenderController.RejectingOutgoingMessageWriter

Field Summary

Fields inherited from class AMQPBridgeToSenderController

bridgeManager, configuration, controllerId, coreLargeMessageWriter, coreMessageWriter, largeMessageWriter, metrics, policy, policyManager, senderContext, senderInfo, serverConsumer, session, sessionSPI, standardMessageWriter, tunnelCoreMessages

Fields inherited from interface SenderController

REJECTING_MESSAGE_WRITER

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected org.apache.activemq.artemis.core.server.ServerConsumer	createServerConsumer(ProtonServerSenderContext senderContext)	The subclass must implement this and create an appropriately configured server consumer based on the properties of the AMQP link and the role of the implemented sender type.
AMQPBridgeAddressPolicy	getPolicy()
AMQPBridgeToSenderController.SenderRole	getRole()	Returns an enumeration describing the role of the sender controller implementation.
protected void	handleLinkLocallyClosed(org.apache.qpid.proton.amqp.transport.ErrorCondition error)	Subclasses should react to link local close by cleaning up resources.
protected void	handleLinkRemotelyClosed()	Subclasses should react to link remote close by cleaning up any resources

Methods inherited from class AMQPBridgeToSenderController

close, close, getBridgeManager, getMessagesSent, getPolicyManager, getRoutingType, getSenderContext, getSenderInfo, getServer, getServerConsumer, getSessionCallback, getSessionContext, init, selectOutgoingMessageWriter

Methods inherited from class Object

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

Constructor Details

AMQPBridgeToAddressSenderController

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

Throws:

ActiveMQAMQPException

Method Details

getRole

public AMQPBridgeToSenderController.SenderRole getRole()

Description copied from class: AMQPBridgeToSenderController

Returns an enumeration describing the role of the sender controller implementation.

Specified by:

getRole in class AMQPBridgeToSenderController

Returns:

an enumeration describing the role of the sender controller implementation

getPolicy

public AMQPBridgeAddressPolicy getPolicy()

handleLinkRemotelyClosed

protected void handleLinkRemotelyClosed()

Description copied from class: AMQPBridgeToSenderController

Subclasses should react to link remote close by cleaning up any resources

Overrides:

handleLinkRemotelyClosed in class AMQPBridgeToSenderController

handleLinkLocallyClosed

protected void handleLinkLocallyClosed(org.apache.qpid.proton.amqp.transport.ErrorCondition error)

Description copied from class: AMQPBridgeToSenderController

Subclasses should react to link local close by cleaning up resources.

Overrides:

handleLinkLocallyClosed in class AMQPBridgeToSenderController

Parameters:

error - The error that triggered the local close or null if no error.

createServerConsumer

protected org.apache.activemq.artemis.core.server.ServerConsumer createServerConsumer(ProtonServerSenderContext senderContext)
                                                                               throws Exception

Description copied from class: AMQPBridgeToSenderController

The subclass must implement this and create an appropriately configured server consumer based on the properties of the AMQP link and the role of the implemented sender type.

Specified by:

createServerConsumer in class AMQPBridgeToSenderController

Parameters:

senderContext - The server sender context that this controller was created for.

Returns:

a new ServerConsumer instance that will send messages to the remote peer.

Throws:

Exception - if an error occurs while creating the server consumer.