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.SenderRoleNested 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, tunnelCoreMessagesFields inherited from interface SenderController
REJECTING_MESSAGE_WRITER -
Constructor Summary
ConstructorsConstructorDescriptionAMQPBridgeToAddressSenderController(AMQPBridgeSenderInfo senderInfo, AMQPBridgeSenderConfiguration configuration, AMQPBridgeToPolicyManager policyManager, AMQPSessionContext session, AMQPBridgeMetrics.SenderMetrics metrics) -
Method Summary
Modifier and TypeMethodDescriptionprotected org.apache.activemq.artemis.core.server.ServerConsumercreateServerConsumer(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.getRole()Returns an enumeration describing the role of the sender controller implementation.protected voidhandleLinkLocallyClosed(org.apache.qpid.proton.amqp.transport.ErrorCondition error) Subclasses should react to link local close by cleaning up resources.protected voidSubclasses should react to link remote close by cleaning up any resourcesMethods inherited from class AMQPBridgeToSenderController
close, close, getBridgeManager, getMessagesSent, getPolicyManager, getRoutingType, getSenderContext, getSenderInfo, getServer, getServerConsumer, getSessionCallback, getSessionContext, init, selectOutgoingMessageWriter
-
Constructor Details
-
AMQPBridgeToAddressSenderController
public AMQPBridgeToAddressSenderController(AMQPBridgeSenderInfo senderInfo, AMQPBridgeSenderConfiguration configuration, AMQPBridgeToPolicyManager policyManager, AMQPSessionContext session, AMQPBridgeMetrics.SenderMetrics metrics) throws ActiveMQAMQPException - Throws:
ActiveMQAMQPException
-
-
Method Details
-
getRole
Description copied from class:AMQPBridgeToSenderControllerReturns an enumeration describing the role of the sender controller implementation.- Specified by:
getRolein classAMQPBridgeToSenderController- Returns:
- an enumeration describing the role of the sender controller implementation
-
getPolicy
-
handleLinkRemotelyClosed
protected void handleLinkRemotelyClosed()Description copied from class:AMQPBridgeToSenderControllerSubclasses should react to link remote close by cleaning up any resources- Overrides:
handleLinkRemotelyClosedin classAMQPBridgeToSenderController
-
handleLinkLocallyClosed
protected void handleLinkLocallyClosed(org.apache.qpid.proton.amqp.transport.ErrorCondition error) Description copied from class:AMQPBridgeToSenderControllerSubclasses should react to link local close by cleaning up resources.- Overrides:
handleLinkLocallyClosedin classAMQPBridgeToSenderController- 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:AMQPBridgeToSenderControllerThe 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:
createServerConsumerin classAMQPBridgeToSenderController- Parameters:
senderContext- The server sender context that this controller was created for.- Returns:
- a new
ServerConsumerinstance that will send messages to the remote peer. - Throws:
Exception- if an error occurs while creating the server consumer.
-