Class FederationReceiveFromQueuePolicy

java.lang.Object

org.apache.activemq.artemis.protocol.amqp.federation.FederationReceiveFromQueuePolicy

All Implemented Interfaces:

BiPredicate<String,String>, FederationReceiveFromResourcePolicy

public class FederationReceiveFromQueuePolicy
extends Object
implements FederationReceiveFromResourcePolicy, BiPredicate<String,String>

Policy used to provide federation of remote to local broker queues, once created the policy configuration is immutable.

Constructor Summary

Constructors

Constructor	Description
FederationReceiveFromQueuePolicy(String name, boolean includeFederated, int priorotyAdjustment, Collection<Map.Entry<String,String>> includeQueues, Collection<Map.Entry<String,String>> excludeQueues, Map<String,Object> properties, TransformerConfiguration transformerConfig, WildcardConfiguration wildcardConfig)

Method Summary

Modifier and Type	Method	Description
Collection<Map.Entry<String,String>>	getExcludes()
Collection<Map.Entry<String,String>>	getIncludes()
String	getPolicyName()	Returns the name assigned to this federation policy.
FederationType	getPolicyType()	Returns the federation type this policy configuration defines.
int	getPriorityAjustment()
Map<String,Object>	getProperties()	Returns a Map of properties that were used in the policy configuration.
TransformerConfiguration	getTransformerConfiguration()	Returns the TransformerConfiguration that was specified in the policy configuration.
boolean	isIncludeFederated()
boolean	test(String address, String queue)
boolean	testQueue(String queue)

Methods inherited from class Object

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

Methods inherited from interface BiPredicate

and, negate, or

Constructor Details

FederationReceiveFromQueuePolicy

public FederationReceiveFromQueuePolicy(String name,
 boolean includeFederated,
 int priorotyAdjustment,
 Collection<Map.Entry<String,String>> includeQueues,
 Collection<Map.Entry<String,String>> excludeQueues,
 Map<String,Object> properties,
 TransformerConfiguration transformerConfig,
 WildcardConfiguration wildcardConfig)

Method Details

getPolicyType

public FederationType getPolicyType()

Description copied from interface: FederationReceiveFromResourcePolicy

Returns the federation type this policy configuration defines.

Specified by:

getPolicyType in interface FederationReceiveFromResourcePolicy

Returns:

the federation type this policy configuration defines

getPolicyName

public String getPolicyName()

Description copied from interface: FederationReceiveFromResourcePolicy

Returns the name assigned to this federation policy.

Specified by:

getPolicyName in interface FederationReceiveFromResourcePolicy

Returns:

the name assigned to this federation policy

isIncludeFederated

public boolean isIncludeFederated()

getPriorityAjustment

public int getPriorityAjustment()

getIncludes

public Collection<Map.Entry<String,String>> getIncludes()

getExcludes

public Collection<Map.Entry<String,String>> getExcludes()

getProperties

public Map<String,Object> getProperties()

Description copied from interface: FederationReceiveFromResourcePolicy

Returns a Map of properties that were used in the policy configuration.

Specified by:

getProperties in interface FederationReceiveFromResourcePolicy

Returns:

a Map of properties that were used in the policy configuration

getTransformerConfiguration

public TransformerConfiguration getTransformerConfiguration()

Description copied from interface: FederationReceiveFromResourcePolicy

Returns the TransformerConfiguration that was specified in the policy configuration.

Specified by:

getTransformerConfiguration in interface FederationReceiveFromResourcePolicy

Returns:

the TransformerConfiguration that was specified in the policy configuration

testQueue

public boolean testQueue(String queue)

test

public boolean test(String address,
 String queue)

Specified by:

test in interface BiPredicate<String,String>