Package org.apache.activemq.artemis.core.config.amqpBrokerConnectivity

Class AMQPFederatedBrokerConnectionElement

java.lang.Object

org.apache.activemq.artemis.core.config.amqpBrokerConnectivity.AMQPBrokerConnectionElement

org.apache.activemq.artemis.core.config.amqpBrokerConnectivity.AMQPFederatedBrokerConnectionElement

All Implemented Interfaces:

Serializable

public class AMQPFederatedBrokerConnectionElement
extends AMQPBrokerConnectionElement

Configuration for broker federation that is managed over an AMQP broker connection.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
AMQPFederatedBrokerConnectionElement()
AMQPFederatedBrokerConnectionElement(String name)

Method Summary

Modifier and Type	Method	Description
AMQPFederatedBrokerConnectionElement	addLocalAddressPolicy(AMQPFederationAddressPolicyElement localAddressPolicy)
AMQPFederatedBrokerConnectionElement	addLocalQueuePolicy(AMQPFederationQueuePolicyElement localQueuePolicy)
AMQPFederatedBrokerConnectionElement	addProperty(String key, Number value)	Adds the given property key and value to the federation configuration element.
AMQPFederatedBrokerConnectionElement	addProperty(String key, String value)	Adds the given property key and value to the federation configuration element.
AMQPFederatedBrokerConnectionElement	addRemoteAddressPolicy(AMQPFederationAddressPolicyElement remoteAddressPolicy)
AMQPFederatedBrokerConnectionElement	addRemoteQueuePolicy(AMQPFederationQueuePolicyElement remoteQueuePolicy)
boolean	equals(Object obj)
Set<AMQPFederationAddressPolicyElement>	getLocalAddressPolicies()
Set<AMQPFederationQueuePolicyElement>	getLocalQueuePolicies()
Map<String,Object>	getProperties()
Set<AMQPFederationAddressPolicyElement>	getRemoteAddressPolicies()
Set<AMQPFederationQueuePolicyElement>	getRemoteQueuePolicies()
int	hashCode()
AMQPFederatedBrokerConnectionElement	setType(AMQPBrokerConnectionAddressType type)

Methods inherited from class org.apache.activemq.artemis.core.config.amqpBrokerConnectivity.AMQPBrokerConnectionElement

getMatchAddress, getName, getParent, getQueueName, getType, match, match, setMatchAddress, setMatchAddress, setName, setParent, setQueueName, setQueueName

Methods inherited from class java.lang.Object

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

Constructor Details

AMQPFederatedBrokerConnectionElement

public AMQPFederatedBrokerConnectionElement()

AMQPFederatedBrokerConnectionElement

public AMQPFederatedBrokerConnectionElement(String name)

Method Details

setType

public AMQPFederatedBrokerConnectionElement setType(AMQPBrokerConnectionAddressType type)

Overrides:

setType in class AMQPBrokerConnectionElement

getRemoteAddressPolicies

public Set<AMQPFederationAddressPolicyElement> getRemoteAddressPolicies()

Returns:

the configured remote address policy set.

addRemoteAddressPolicy

public AMQPFederatedBrokerConnectionElement addRemoteAddressPolicy(AMQPFederationAddressPolicyElement remoteAddressPolicy)

Parameters:

remoteAddressPolicy - the policy to add to the set of remote address policies set

Returns:

this configuration element instance.

getRemoteQueuePolicies

public Set<AMQPFederationQueuePolicyElement> getRemoteQueuePolicies()

Returns:

the configured remote queue policy set.

addRemoteQueuePolicy

public AMQPFederatedBrokerConnectionElement addRemoteQueuePolicy(AMQPFederationQueuePolicyElement remoteQueuePolicy)

Parameters:

remoteQueuePolicy - the policy to add to the set of remote queue policies set

Returns:

this configuration element instance.

getLocalAddressPolicies

public Set<AMQPFederationAddressPolicyElement> getLocalAddressPolicies()

Returns:

the configured local address policy set.

addLocalAddressPolicy

public AMQPFederatedBrokerConnectionElement addLocalAddressPolicy(AMQPFederationAddressPolicyElement localAddressPolicy)

Parameters:

localAddressPolicy - the policy to add to the set of local address policies set

Returns:

this configuration element instance.

getLocalQueuePolicies

public Set<AMQPFederationQueuePolicyElement> getLocalQueuePolicies()

Returns:

the configured local queue policy set.

addLocalQueuePolicy

public AMQPFederatedBrokerConnectionElement addLocalQueuePolicy(AMQPFederationQueuePolicyElement localQueuePolicy)

Parameters:

localQueuePolicy - the policy to add to the set of local queue policies set

Returns:

this configuration element instance.

addProperty

public AMQPFederatedBrokerConnectionElement addProperty(String key,
 String value)

Adds the given property key and value to the federation configuration element.

Parameters:

key - The key that identifies the property

value - The value associated with the property key.

Returns:

this configuration element instance.

addProperty

public AMQPFederatedBrokerConnectionElement addProperty(String key,
 Number value)

Adds the given property key and value to the federation configuration element.

Parameters:

key - The key that identifies the property

value - The value associated with the property key.

Returns:

this configuration element instance.

getProperties

public Map<String,Object> getProperties()

Returns:

the collection of configuration properties associated with this federation element.

hashCode

public int hashCode()

Overrides:

hashCode in class AMQPBrokerConnectionElement

equals

public boolean equals(Object obj)

Overrides:

equals in class AMQPBrokerConnectionElement