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
-
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
-
-
-
-
Constructor Detail
-
AMQPFederatedBrokerConnectionElement
public AMQPFederatedBrokerConnectionElement()
-
AMQPFederatedBrokerConnectionElement
public AMQPFederatedBrokerConnectionElement(String name)
-
-
Method Detail
-
setType
public AMQPFederatedBrokerConnectionElement setType(AMQPBrokerConnectionAddressType type)
- Overrides:
setType
in classAMQPBrokerConnectionElement
-
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 propertyvalue
- 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 propertyvalue
- 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 classAMQPBrokerConnectionElement
-
equals
public boolean equals(Object obj)
- Overrides:
equals
in classAMQPBrokerConnectionElement
-
-