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

    • 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 org.apache.activemq.artemis.core.server.cluster.impl.MessageLoadBalancingType getMessageLoadBalancingType()

    • setMessageLoadBalancingType

      public ClusterConnectionConfiguration setMessageLoadBalancingType(org.apache.activemq.artemis.core.server.cluster.impl.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