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

Class ClusterConnectionConfiguration

java.lang.Object

org.apache.activemq.artemis.core.config.ClusterConnectionConfiguration

All Implemented Interfaces:

Serializable

public final class ClusterConnectionConfiguration
extends Object
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ClusterConnectionConfiguration()
ClusterConnectionConfiguration(URI uri)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object obj)
String	getAddress()
long	getCallFailoverTimeout()
long	getCallTimeout()
long	getClientFailureCheckPeriod()
int	getClusterNotificationAttempts()
long	getClusterNotificationInterval()
org.apache.activemq.artemis.utils.uri.URISupport.CompositeData	getCompositeMembers()
int	getConfirmationWindowSize()
long	getConnectionTTL()
String	getConnectorName()
DiscoveryGroupConfiguration	getDiscoveryGroupConfiguration(Configuration configuration)	This method will return the proper discovery configuration from the main configuration
String	getDiscoveryGroupName()
int	getInitialConnectAttempts()
int	getMaxHops()
long	getMaxRetryInterval()
org.apache.activemq.artemis.core.server.cluster.impl.MessageLoadBalancingType	getMessageLoadBalancingType()
int	getMinLargeMessageSize()
String	getName()
int	getProducerWindowSize()
int	getReconnectAttempts()
long	getRetryInterval()
double	getRetryIntervalMultiplier()
List<String>	getStaticConnectors()
TransportConfiguration	getTransportConfiguration(Configuration configuration)
TransportConfiguration[]	getTransportConfigurations(Configuration configuration)	This method will match the configuration and return the proper TransportConfiguration for the Configuration
int	hashCode()
boolean	isAllowDirectConnectionsOnly()
boolean	isDuplicateDetection()
ClusterConnectionConfiguration	setAddress(String address)
ClusterConnectionConfiguration	setAllowDirectConnectionsOnly(boolean allowDirectConnectionsOnly)
ClusterConnectionConfiguration	setCallFailoverTimeout(long callFailoverTimeout)
ClusterConnectionConfiguration	setCallTimeout(long callTimeout)
ClusterConnectionConfiguration	setClientFailureCheckPeriod(long clientFailureCheckPeriod)
ClusterConnectionConfiguration	setClusterNotificationAttempts(int clusterNotificationAttempts)
ClusterConnectionConfiguration	setClusterNotificationInterval(long clusterNotificationInterval)
ClusterConnectionConfiguration	setCompositeMembers(org.apache.activemq.artemis.utils.uri.URISupport.CompositeData members)
ClusterConnectionConfiguration	setConfirmationWindowSize(int confirmationWindowSize)
ClusterConnectionConfiguration	setConnectionTTL(long connectionTTL)
ClusterConnectionConfiguration	setConnectorName(String connectorName)
ClusterConnectionConfiguration	setDiscoveryGroupName(String discoveryGroupName)
ClusterConnectionConfiguration	setDuplicateDetection(boolean duplicateDetection)
ClusterConnectionConfiguration	setInitialConnectAttempts(int initialConnectAttempts)
ClusterConnectionConfiguration	setMaxHops(int maxHops)
ClusterConnectionConfiguration	setMaxRetryInterval(long maxRetryInterval)
ClusterConnectionConfiguration	setMessageLoadBalancingType(org.apache.activemq.artemis.core.server.cluster.impl.MessageLoadBalancingType messageLoadBalancingType)
ClusterConnectionConfiguration	setMinLargeMessageSize(int minLargeMessageSize)
ClusterConnectionConfiguration	setName(String name)
ClusterConnectionConfiguration	setProducerWindowSize(int producerWindowSize)
ClusterConnectionConfiguration	setReconnectAttempts(int reconnectAttempts)
ClusterConnectionConfiguration	setRetryInterval(long retryInterval)
ClusterConnectionConfiguration	setRetryIntervalMultiplier(double retryIntervalMultiplier)
ClusterConnectionConfiguration	setStaticConnectors(List<String> staticConnectors)
String	toString()
boolean	validateConfiguration()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterConnectionConfiguration

public ClusterConnectionConfiguration()

ClusterConnectionConfiguration

public ClusterConnectionConfiguration(URI uri)
                               throws Exception

Throws:

Exception

Method Detail

getName

public String getName()

setName

public ClusterConnectionConfiguration setName(String name)

getAddress

public String getAddress()

setAddress

public ClusterConnectionConfiguration setAddress(String address)

getCompositeMembers

public org.apache.activemq.artemis.utils.uri.URISupport.CompositeData getCompositeMembers()

setCompositeMembers

public ClusterConnectionConfiguration setCompositeMembers(org.apache.activemq.artemis.utils.uri.URISupport.CompositeData members)

getClientFailureCheckPeriod

public long getClientFailureCheckPeriod()

Returns:

the clientFailureCheckPeriod

setClientFailureCheckPeriod

public ClusterConnectionConfiguration setClientFailureCheckPeriod(long clientFailureCheckPeriod)

Parameters:

clientFailureCheckPeriod - the clientFailureCheckPeriod to set

getConnectionTTL

public long getConnectionTTL()

Returns:

the connectionTTL

setConnectionTTL

public ClusterConnectionConfiguration setConnectionTTL(long connectionTTL)

Parameters:

connectionTTL - the connectionTTL to set

getRetryIntervalMultiplier

public double getRetryIntervalMultiplier()

Returns:

the retryIntervalMultiplier

setRetryIntervalMultiplier

public ClusterConnectionConfiguration setRetryIntervalMultiplier(double retryIntervalMultiplier)

Parameters:

retryIntervalMultiplier - the retryIntervalMultiplier to set

getMaxRetryInterval

public long getMaxRetryInterval()

Returns:

the maxRetryInterval

setMaxRetryInterval

public ClusterConnectionConfiguration setMaxRetryInterval(long maxRetryInterval)

Parameters:

maxRetryInterval - the maxRetryInterval to set

getInitialConnectAttempts

public int getInitialConnectAttempts()

Returns:

the initialConnectAttempts

setInitialConnectAttempts

public ClusterConnectionConfiguration setInitialConnectAttempts(int initialConnectAttempts)

Parameters:

initialConnectAttempts - the reconnectAttempts to set

getReconnectAttempts

public int getReconnectAttempts()

Returns:

the reconnectAttempts

setReconnectAttempts

public ClusterConnectionConfiguration setReconnectAttempts(int reconnectAttempts)

Parameters:

reconnectAttempts - the reconnectAttempts to set

getCallTimeout

public long getCallTimeout()

setCallTimeout

public ClusterConnectionConfiguration setCallTimeout(long callTimeout)

Parameters:

callTimeout - the callTimeout to set

getCallFailoverTimeout

public long getCallFailoverTimeout()

setCallFailoverTimeout

public ClusterConnectionConfiguration setCallFailoverTimeout(long callFailoverTimeout)

Parameters:

callFailoverTimeout - the callTimeout to set

getConnectorName

public String getConnectorName()

setConnectorName

public ClusterConnectionConfiguration setConnectorName(String connectorName)

isDuplicateDetection

public boolean isDuplicateDetection()

setDuplicateDetection

public ClusterConnectionConfiguration setDuplicateDetection(boolean duplicateDetection)

Parameters:

duplicateDetection - the duplicateDetection to set

getMessageLoadBalancingType

public org.apache.activemq.artemis.core.server.cluster.impl.MessageLoadBalancingType getMessageLoadBalancingType()

setMessageLoadBalancingType

public ClusterConnectionConfiguration setMessageLoadBalancingType(org.apache.activemq.artemis.core.server.cluster.impl.MessageLoadBalancingType messageLoadBalancingType)

Parameters:

messageLoadBalancingType -

Returns:

getMaxHops

public int getMaxHops()

setMaxHops

public ClusterConnectionConfiguration setMaxHops(int maxHops)

getConfirmationWindowSize

public int getConfirmationWindowSize()

setConfirmationWindowSize

public ClusterConnectionConfiguration setConfirmationWindowSize(int confirmationWindowSize)

getProducerWindowSize

public int getProducerWindowSize()

setProducerWindowSize

public ClusterConnectionConfiguration setProducerWindowSize(int producerWindowSize)

getStaticConnectors

public List<String> getStaticConnectors()

setStaticConnectors

public ClusterConnectionConfiguration setStaticConnectors(List<String> staticConnectors)

getDiscoveryGroupName

public String getDiscoveryGroupName()

setDiscoveryGroupName

public ClusterConnectionConfiguration setDiscoveryGroupName(String discoveryGroupName)

getRetryInterval

public long getRetryInterval()

setRetryInterval

public ClusterConnectionConfiguration setRetryInterval(long retryInterval)

Parameters:

retryInterval - the retryInterval to set

isAllowDirectConnectionsOnly

public boolean isAllowDirectConnectionsOnly()

setAllowDirectConnectionsOnly

public ClusterConnectionConfiguration setAllowDirectConnectionsOnly(boolean allowDirectConnectionsOnly)

getMinLargeMessageSize

public int getMinLargeMessageSize()

Returns:

the minLargeMessageSize

setMinLargeMessageSize

public ClusterConnectionConfiguration setMinLargeMessageSize(int minLargeMessageSize)

Parameters:

minLargeMessageSize - the minLargeMessageSize to set

getClusterNotificationInterval

public long getClusterNotificationInterval()

setClusterNotificationInterval

public ClusterConnectionConfiguration setClusterNotificationInterval(long clusterNotificationInterval)

getClusterNotificationAttempts

public int getClusterNotificationAttempts()

setClusterNotificationAttempts

public ClusterConnectionConfiguration setClusterNotificationAttempts(int clusterNotificationAttempts)

getTransportConfigurations

public TransportConfiguration[] getTransportConfigurations(Configuration configuration)
                                                    throws Exception

This method will match the configuration and return the proper TransportConfiguration for the Configuration

Throws:

Exception

getDiscoveryGroupConfiguration

public DiscoveryGroupConfiguration getDiscoveryGroupConfiguration(Configuration configuration)

This method will return the proper discovery configuration from the main configuration

getTransportConfiguration

public TransportConfiguration getTransportConfiguration(Configuration configuration)

validateConfiguration

public boolean validateConfiguration()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object