Uses of Class
org.apache.activemq.artemis.protocol.amqp.connect.federation.AMQPFederationSenderController
Packages that use AMQPFederationSenderController
-
Uses of AMQPFederationSenderController in org.apache.activemq.artemis.protocol.amqp.connect.federation
Subclasses of AMQPFederationSenderController in org.apache.activemq.artemis.protocol.amqp.connect.federationModifier and TypeClassDescriptionfinal classSenderControllerused when an AMQP federation Address receiver is created and this side of the connection needs to create a matching sender.final classSenderControllerused when an AMQP federation Queue receiver is created and this side of the connection needs to create a matching sender.Fields in org.apache.activemq.artemis.protocol.amqp.connect.federation with type parameters of type AMQPFederationSenderControllerModifier and TypeFieldDescriptionprotected final Consumer<AMQPFederationSenderController> AMQPFederationSenderController.closedListenerMethods in org.apache.activemq.artemis.protocol.amqp.connect.federation that return AMQPFederationSenderControllerModifier and TypeMethodDescriptionprotected AMQPFederationSenderControllerAMQPFederationRemoteAddressPolicyManager.createSenderController(Consumer<AMQPFederationSenderController> closedListener) protected abstract AMQPFederationSenderControllerAMQPFederationRemotePolicyManager.createSenderController(Consumer<AMQPFederationSenderController> closedListener) Subclass creates the actual type of federation sender controller specific to that manager type.protected AMQPFederationSenderControllerAMQPFederationRemoteQueuePolicyManager.createSenderController(Consumer<AMQPFederationSenderController> closedListener) AMQPFederationRemotePolicyManager.newSenderController()Create a newAMQPFederationSenderControllerinstance for use by newly opened AMQP federation sender links initiated from the remote broker based on federation policies that have been configured or sent to that broker instance.Methods in org.apache.activemq.artemis.protocol.amqp.connect.federation with parameters of type AMQPFederationSenderControllerModifier and TypeMethodDescriptionstatic voidAMQPFederationManagementSupport.registerFederationSourceProducer(String brokerConnectionName, AMQPFederationSenderController sender) Registers the federation producer with the server management services on the source.static voidAMQPFederationManagementSupport.registerFederationTargetProducer(String remoteNodeId, String brokerConnectionName, AMQPFederationSenderController sender) Registers the federation producer with the server management services on the target.static voidAMQPFederationManagementSupport.unregisterFederationSourceProducer(String brokerConnectionName, AMQPFederationSenderController sender) Unregisters the federation producer with the server management services on the source.static voidAMQPFederationManagementSupport.unregisterFederationTargetProducer(String remoteNodeId, String brokerConnectionName, AMQPFederationSenderController sender) Unregisters the federation producer with the server management services on the target.Method parameters in org.apache.activemq.artemis.protocol.amqp.connect.federation with type arguments of type AMQPFederationSenderControllerModifier and TypeMethodDescriptionprotected AMQPFederationSenderControllerAMQPFederationRemoteAddressPolicyManager.createSenderController(Consumer<AMQPFederationSenderController> closedListener) protected abstract AMQPFederationSenderControllerAMQPFederationRemotePolicyManager.createSenderController(Consumer<AMQPFederationSenderController> closedListener) Subclass creates the actual type of federation sender controller specific to that manager type.protected AMQPFederationSenderControllerAMQPFederationRemoteQueuePolicyManager.createSenderController(Consumer<AMQPFederationSenderController> closedListener) Constructors in org.apache.activemq.artemis.protocol.amqp.connect.federation with parameters of type AMQPFederationSenderControllerModifierConstructorDescriptionAMQPFederationProducerControlType(AMQPFederationSenderController senderController) Constructor parameters in org.apache.activemq.artemis.protocol.amqp.connect.federation with type arguments of type AMQPFederationSenderControllerModifierConstructorDescriptionAMQPFederationAddressSenderController(AMQPFederationRemoteAddressPolicyManager manager, AMQPFederationMetrics.ProducerMetrics metrics, Consumer<AMQPFederationSenderController> closedListener) AMQPFederationQueueSenderController(AMQPFederationRemoteQueuePolicyManager manager, AMQPFederationMetrics.ProducerMetrics metrics, Consumer<AMQPFederationSenderController> closedListener) AMQPFederationSenderController(AMQPFederationRemotePolicyManager manager, AMQPFederationMetrics.ProducerMetrics metrics, Consumer<AMQPFederationSenderController> closedListener)