Class AMQPFederationRemoteQueuePolicyManager

java.lang.Object

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

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

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

public final class AMQPFederationRemoteQueuePolicyManager
extends AMQPFederationRemotePolicyManager

Policy manager that manages state data for remote AMQP Federation Queue policies and their associated senders. These managers are a result either of a local federation configuration that sender federation policies to the remote side of the connection or at the remote target they appear when the remote is consuming messages from the target based on local federation configurations.

Nested Class Summary

Nested classes/interfaces inherited from class AMQPFederationPolicyManager

AMQPFederationPolicyManager.State

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_REMOTE_QUEUE_POLICY_NAME	Name used when the remote queue policy name is not present due to having connected to an older broker instance that does not fill in the link property that carries the policy name.

Fields inherited from class AMQPFederationPolicyManager

connected, federation, metrics, policyName, policyType, server, session, state

Constructor Summary

Constructors

Constructor	Description
AMQPFederationRemoteQueuePolicyManager(AMQPFederation federation, AMQPFederationMetrics metrics, String policyName)

Method Summary

Modifier and Type	Method	Description
protected AMQPFederationSenderController	createSenderController(Consumer<AMQPFederationSenderController> closedListener)	Subclass creates the actual type of federation sender controller specific to that manager type.

Methods inherited from class AMQPFederationRemotePolicyManager

handleConnectionInterrupted, handleConnectionRestored, handleManagerInitialized, handleManagerShutdown, handleManagerStarted, handleManagerStopped, newSenderController

Methods inherited from class AMQPFederationPolicyManager

connectionInterrupted, connectionRestored, failIfShutdown, getFederation, getMetrics, getPolicyName, getPolicyType, initialize, isActive, isConnected, isStarted, shutdown, start, stop

Methods inherited from class Object

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

Field Details

DEFAULT_REMOTE_QUEUE_POLICY_NAME

public static final String DEFAULT_REMOTE_QUEUE_POLICY_NAME

Name used when the remote queue policy name is not present due to having connected to an older broker instance that does not fill in the link property that carries the policy name.

See Also:

• Constant Field Values

Constructor Details

AMQPFederationRemoteQueuePolicyManager

public AMQPFederationRemoteQueuePolicyManager(AMQPFederation federation,
 AMQPFederationMetrics metrics,
 String policyName)

Method Details

createSenderController

protected AMQPFederationSenderController createSenderController(Consumer<AMQPFederationSenderController> closedListener)
                                                         throws ActiveMQAMQPException

Description copied from class: AMQPFederationRemotePolicyManager

Subclass creates the actual type of federation sender controller specific to that manager type.

Specified by:

createSenderController in class AMQPFederationRemotePolicyManager

Parameters:

closedListener - The closed listener to provide to the new sender controller.

Returns:

a new AMQPFederationSenderController to be assigned to a sender context

Throws:

ActiveMQAMQPException - if an error occurs while creating the controller