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()
String	getClientId()
int	getClusterNotificationAttempts()
long	getClusterNotificationInterval()
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()
MessageLoadBalancingType	getMessageLoadBalancingType()
int	getMinLargeMessageSize()
String	getName()
int	getProducerWindowSize()
int	getReconnectAttempts()
long	getRetryInterval()
double	getRetryIntervalMultiplier()
List<String>	getStaticConnectors()
int	getTopologyScannerAttempts()
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	setClientId(String clientId)
ClusterConnectionConfiguration	setClusterNotificationAttempts(int clusterNotificationAttempts)
ClusterConnectionConfiguration	setClusterNotificationInterval(long clusterNotificationInterval)
ClusterConnectionConfiguration	setCompositeMembers(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(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)
ClusterConnectionConfiguration	setTopologyScannerAttempts(int topologyScannerAttempts)
String	toString()
boolean	validateConfiguration()

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterConnectionConfiguration

public ClusterConnectionConfiguration()

ClusterConnectionConfiguration

public ClusterConnectionConfiguration(URI uri)
                               throws Exception

Throws:

Exception

Method Details

getName

public String getName()

setName

public ClusterConnectionConfiguration setName(String name)

getAddress

public String getAddress()

setAddress

public ClusterConnectionConfiguration setAddress(String address)

getCompositeMembers

public URISupport.CompositeData getCompositeMembers()

setCompositeMembers

public ClusterConnectionConfiguration setCompositeMembers(URISupport.CompositeData members)

getClientFailureCheckPeriod

public long getClientFailureCheckPeriod()

setClientFailureCheckPeriod

public ClusterConnectionConfiguration setClientFailureCheckPeriod(long clientFailureCheckPeriod)

getConnectionTTL

public long getConnectionTTL()

setConnectionTTL

public ClusterConnectionConfiguration setConnectionTTL(long connectionTTL)

getRetryIntervalMultiplier

public double getRetryIntervalMultiplier()

setRetryIntervalMultiplier

public ClusterConnectionConfiguration setRetryIntervalMultiplier(double retryIntervalMultiplier)

getMaxRetryInterval

public long getMaxRetryInterval()

setMaxRetryInterval

public ClusterConnectionConfiguration setMaxRetryInterval(long maxRetryInterval)

getInitialConnectAttempts

public int getInitialConnectAttempts()

setInitialConnectAttempts

public ClusterConnectionConfiguration setInitialConnectAttempts(int initialConnectAttempts)

getReconnectAttempts

public int getReconnectAttempts()

setReconnectAttempts

public ClusterConnectionConfiguration setReconnectAttempts(int reconnectAttempts)

getCallTimeout

public long getCallTimeout()

setCallTimeout

public ClusterConnectionConfiguration setCallTimeout(long callTimeout)

getCallFailoverTimeout

public long getCallFailoverTimeout()

setCallFailoverTimeout

public ClusterConnectionConfiguration setCallFailoverTimeout(long callFailoverTimeout)

getConnectorName

public String getConnectorName()

setConnectorName

public ClusterConnectionConfiguration setConnectorName(String connectorName)

isDuplicateDetection

public boolean isDuplicateDetection()

setDuplicateDetection

public ClusterConnectionConfiguration setDuplicateDetection(boolean duplicateDetection)

getMessageLoadBalancingType

public MessageLoadBalancingType getMessageLoadBalancingType()

setMessageLoadBalancingType

public ClusterConnectionConfiguration setMessageLoadBalancingType(MessageLoadBalancingType messageLoadBalancingType)

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)

isAllowDirectConnectionsOnly

public boolean isAllowDirectConnectionsOnly()

setAllowDirectConnectionsOnly

public ClusterConnectionConfiguration setAllowDirectConnectionsOnly(boolean allowDirectConnectionsOnly)

getMinLargeMessageSize

public int getMinLargeMessageSize()

setMinLargeMessageSize

public ClusterConnectionConfiguration setMinLargeMessageSize(int minLargeMessageSize)

getClusterNotificationInterval

public long getClusterNotificationInterval()

setClusterNotificationInterval

public ClusterConnectionConfiguration setClusterNotificationInterval(long clusterNotificationInterval)

getClusterNotificationAttempts

public int getClusterNotificationAttempts()

setClusterNotificationAttempts

public ClusterConnectionConfiguration setClusterNotificationAttempts(int clusterNotificationAttempts)

getClientId

public String getClientId()

setClientId

public ClusterConnectionConfiguration setClientId(String clientId)

getTopologyScannerAttempts

public int getTopologyScannerAttempts()

setTopologyScannerAttempts

public ClusterConnectionConfiguration setTopologyScannerAttempts(int topologyScannerAttempts)

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