Class AMQPFederationAddressSenderController

java.lang.Object

org.apache.activemq.artemis.protocol.amqp.connect.federation.AMQPFederationSenderController

org.apache.activemq.artemis.protocol.amqp.connect.federation.AMQPFederationAddressSenderController

All Implemented Interfaces:

SenderController

public final class AMQPFederationAddressSenderController
extends AMQPFederationSenderController

SenderController used when an AMQP federation Address receiver is created and this side of the connection needs to create a matching sender. The address sender controller must check on initialization if the address exists and if not it should create it using the configuration values supplied in the link source properties that control the lifetime of the address once the link is closed.

Nested Class Summary

Nested classes/interfaces inherited from class AMQPFederationSenderController

AMQPFederationSenderController.Role

Nested classes/interfaces inherited from interface SenderController

SenderController.RejectingOutgoingMessageWriter

Field Summary

Fields inherited from class AMQPFederationSenderController

closedListener, controllerId, coreLargeMessageWriter, coreMessageWriter, federation, largeMessageWriter, manager, metrics, resourceDeletedAction, senderContext, serverConsumer, session, sessionSPI, standardMessageWriter, tunnelCoreMessages

Fields inherited from interface SenderController

REJECTING_MESSAGE_WRITER

Constructor Summary

Constructors

Constructor	Description
AMQPFederationAddressSenderController(AMQPFederationRemoteAddressPolicyManager manager, AMQPFederationMetrics.ProducerMetrics metrics, Consumer<AMQPFederationSenderController> closedListener)

Method Summary

Modifier and Type	Method	Description
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.
AMQPFederationSenderController.Role	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 AMQPFederationSenderController

close, close, getFederation, getMessagesSent, getPolicyManager, getRoutingType, getSenderContext, getServer, getServerConsumer, getSessionCallback, getSessionContext, init, registerRemoteLinkClosedInterceptor, selectOutgoingMessageWriter

Methods inherited from class Object

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

Constructor Details

AMQPFederationAddressSenderController

public AMQPFederationAddressSenderController(AMQPFederationRemoteAddressPolicyManager manager,
 AMQPFederationMetrics.ProducerMetrics metrics,
 Consumer<AMQPFederationSenderController> closedListener)
                                      throws ActiveMQAMQPException

Throws:

ActiveMQAMQPException

Method Details

getRole

public AMQPFederationSenderController.Role getRole()

Description copied from class: AMQPFederationSenderController

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

Specified by:

getRole in class AMQPFederationSenderController

Returns:

an enumeration describing the role of the sender controller implementation

createServerConsumer

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

Description copied from class: AMQPFederationSenderController

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 AMQPFederationSenderController

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.

handleLinkRemotelyClosed

protected void handleLinkRemotelyClosed()

Description copied from class: AMQPFederationSenderController

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

Overrides:

handleLinkRemotelyClosed in class AMQPFederationSenderController

handleLinkLocallyClosed

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

Description copied from class: AMQPFederationSenderController

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

Overrides:

handleLinkLocallyClosed in class AMQPFederationSenderController

Parameters:

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