Uses of Class
org.apache.activemq.artemis.protocol.amqp.federation.FederationReceiveFromQueuePolicy
Packages that use FederationReceiveFromQueuePolicy
-
Uses of FederationReceiveFromQueuePolicy in org.apache.activemq.artemis.protocol.amqp.connect.federation
Fields in org.apache.activemq.artemis.protocol.amqp.connect.federation declared as FederationReceiveFromQueuePolicyModifier and TypeFieldDescriptionprotected final FederationReceiveFromQueuePolicyAMQPFederationQueuePolicyManager.policyMethods in org.apache.activemq.artemis.protocol.amqp.connect.federation that return FederationReceiveFromQueuePolicyModifier and TypeMethodDescriptionAMQPFederationPolicySupport.create(AMQPFederationQueuePolicyElement element, WildcardConfiguration wildcards) From the broker AMQP broker connection configuration element and the configured wild-card settings create an queue match policy.AMQPFederationPolicySupport.decodeReceiveFromQueuePolicy(AMQPMessage message, WildcardConfiguration wildcardConfig) Given an AMQP Message decode anFederationReceiveFromQueuePolicyfrom it and return the decoded value.AMQPFederationQueuePolicyManager.getPolicy()Returns the receive from address policy that backs the address policy manager.Methods in org.apache.activemq.artemis.protocol.amqp.connect.federation with parameters of type FederationReceiveFromQueuePolicyModifier and TypeMethodDescriptionAMQPFederation.addQueueMatchPolicy(FederationReceiveFromQueuePolicy queuePolicy) Adds a newFederationReceiveFromQueuePolicyentry to the set of policies that this federation will use to create demand on the remote when local demand is present.AMQPFederationSource.addRemoteQueueMatchPolicy(FederationReceiveFromQueuePolicy queuePolicy) Adds a newFederationReceiveFromQueuePolicyentry to the set of policies that the remote end of this federation will use to create demand on the this server when local demand is present.static AMQPMessageAMQPFederationPolicySupport.encodeQueuePolicyControlMessage(FederationReceiveFromQueuePolicy policy) Create an AMQP Message used to instruct the remote peer that it should perform Federation operations on the givenFederationReceiveFromQueuePolicy.voidAMQPFederationCommandDispatcher.sendPolicy(FederationReceiveFromQueuePolicy policy) Sends the givenFederationReceiveFromQueuePolicyinstance using the control link which should instruct the remote to begin federation operations back to this peer for matching remote queues with demand.Constructors in org.apache.activemq.artemis.protocol.amqp.connect.federation with parameters of type FederationReceiveFromQueuePolicyModifierConstructorDescriptionAMQPFederationQueuePolicyManager(AMQPFederation federation, AMQPFederationMetrics metrics, FederationReceiveFromQueuePolicy queuePolicy)