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:

  • 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 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)

    • getClientId

      public String getClientId()

    • setClientId

      public ClusterConnectionConfiguration setClientId(String clientId)

    • 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