Class AMQPBridgeToQueueSender.AMQPBridgeToQueueSenderController

java.lang.Object

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

org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgeToQueueSender.AMQPBridgeToQueueSenderController

All Implemented Interfaces:

SenderController

Enclosing class:

AMQPBridgeToQueueSender

public static class AMQPBridgeToQueueSender.AMQPBridgeToQueueSenderController
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
AMQPBridgeToQueueSenderController(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.
AMQPBridgeQueuePolicy	getPolicy()
AMQPBridgeToSenderController.SenderRole	getRole()	Returns an enumeration describing the role of the sender controller implementation.

Methods inherited from class AMQPBridgeToSenderController

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

Methods inherited from class Object

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

Constructor Details

AMQPBridgeToQueueSenderController

public AMQPBridgeToQueueSenderController(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 AMQPBridgeQueuePolicy getPolicy()

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.