Class BridgeConfiguration

java.lang.Object
org.apache.activemq.artemis.core.config.BridgeConfiguration
All Implemented Interfaces:
Serializable

public final class BridgeConfiguration extends Object implements Serializable
See Also:
  • Field Details

    • NAME

      public static String NAME
    • QUEUE_NAME

      public static String QUEUE_NAME
    • FORWARDING_ADDRESS

      public static String FORWARDING_ADDRESS
    • FILTER_STRING

      public static String FILTER_STRING
    • STATIC_CONNECTORS

      public static String STATIC_CONNECTORS
    • DISCOVERY_GROUP_NAME

      public static String DISCOVERY_GROUP_NAME
    • HA

      public static String HA
    • TRANSFORMER_CONFIGURATION

      public static String TRANSFORMER_CONFIGURATION
    • RETRY_INTERVAL

      public static String RETRY_INTERVAL
    • RETRY_INTERVAL_MULTIPLIER

      public static String RETRY_INTERVAL_MULTIPLIER
    • INITIAL_CONNECT_ATTEMPTS

      public static String INITIAL_CONNECT_ATTEMPTS
    • RECONNECT_ATTEMPTS

      public static String RECONNECT_ATTEMPTS
    • RECONNECT_ATTEMPTS_ON_SAME_NODE

      public static String RECONNECT_ATTEMPTS_ON_SAME_NODE
    • USE_DUPLICATE_DETECTION

      public static String USE_DUPLICATE_DETECTION
    • CONFIRMATION_WINDOW_SIZE

      public static String CONFIRMATION_WINDOW_SIZE
    • PRODUCER_WINDOW_SIZE

      public static String PRODUCER_WINDOW_SIZE
    • CLIENT_FAILURE_CHECK_PERIOD

      public static String CLIENT_FAILURE_CHECK_PERIOD
    • USER

      public static String USER
    • PASSWORD

      public static String PASSWORD
    • CONNECTION_TTL

      public static String CONNECTION_TTL
    • MAX_RETRY_INTERVAL

      public static String MAX_RETRY_INTERVAL
    • MIN_LARGE_MESSAGE_SIZE

      public static String MIN_LARGE_MESSAGE_SIZE
    • CALL_TIMEOUT

      public static String CALL_TIMEOUT
    • ROUTING_TYPE

      public static String ROUTING_TYPE
    • CONCURRENCY

      public static String CONCURRENCY
    • CONFIGURATION_MANAGED

      public static String CONFIGURATION_MANAGED
    • PENDING_ACK_TIMEOUT

      public static String PENDING_ACK_TIMEOUT
    • CLIENT_ID

      public static String CLIENT_ID
  • Constructor Details

    • BridgeConfiguration

      public BridgeConfiguration()
    • BridgeConfiguration

      public BridgeConfiguration(BridgeConfiguration other)
    • BridgeConfiguration

      public BridgeConfiguration(String name)
  • Method Details

    • set

      public BridgeConfiguration set(String key, String value)
      Set the value of a parameter based on its "key" String. Valid key names and corresponding static final are:

      The String-based values will be converted to the proper value types based on the underlying property. For example, if you pass the value "TRUE" for the key "auto-created" the String "TRUE" will be converted to the Boolean true.

      Parameters:
      key - the key to set to the value
      value - the value to set for the key
      Returns:
      this BridgeConfiguration
    • getName

      public String getName()
    • setName

      public BridgeConfiguration setName(String name)
      Parameters:
      name - the name to set
    • getParentName

      public String getParentName()
    • setParentName

      public BridgeConfiguration setParentName(String parentName)
    • getQueueName

      public String getQueueName()
    • setQueueName

      public BridgeConfiguration setQueueName(String queueName)
      Parameters:
      queueName - the queueName to set
    • getConnectionTTL

      public long getConnectionTTL()
      Returns:
      the connectionTTL
    • setConnectionTTL

      public BridgeConfiguration setConnectionTTL(long connectionTTL)
    • getMaxRetryInterval

      public long getMaxRetryInterval()
      Returns:
      the maxRetryInterval
    • setMaxRetryInterval

      public BridgeConfiguration setMaxRetryInterval(long maxRetryInterval)
    • getForwardingAddress

      public String getForwardingAddress()
    • setForwardingAddress

      public BridgeConfiguration setForwardingAddress(String forwardingAddress)
      Parameters:
      forwardingAddress - the forwardingAddress to set
    • getFilterString

      public String getFilterString()
    • setFilterString

      public BridgeConfiguration setFilterString(String filterString)
      Parameters:
      filterString - the filterString to set
    • getTransformerConfiguration

      public TransformerConfiguration getTransformerConfiguration()
    • setTransformerConfiguration

      public BridgeConfiguration setTransformerConfiguration(TransformerConfiguration transformerConfiguration)
      Parameters:
      transformerConfiguration - the transformerConfiguration to set
    • getStaticConnectors

      public List<String> getStaticConnectors()
    • setStaticConnectors

      public BridgeConfiguration setStaticConnectors(List<String> staticConnectors)
      Parameters:
      staticConnectors - the staticConnectors to set
    • getDiscoveryGroupName

      public String getDiscoveryGroupName()
    • setDiscoveryGroupName

      public BridgeConfiguration setDiscoveryGroupName(String discoveryGroupName)
      Parameters:
      discoveryGroupName - the discoveryGroupName to set
    • isHA

      public boolean isHA()
    • setHA

      public BridgeConfiguration setHA(boolean ha)
      Parameters:
      ha - is the bridge supporting HA?
    • getRetryInterval

      public long getRetryInterval()
    • setRetryInterval

      public BridgeConfiguration setRetryInterval(long retryInterval)
      Parameters:
      retryInterval - the retryInterval to set
    • getRetryIntervalMultiplier

      public double getRetryIntervalMultiplier()
    • setRetryIntervalMultiplier

      public BridgeConfiguration setRetryIntervalMultiplier(double retryIntervalMultiplier)
      Parameters:
      retryIntervalMultiplier - the retryIntervalMultiplier to set
    • getInitialConnectAttempts

      public int getInitialConnectAttempts()
    • setInitialConnectAttempts

      public BridgeConfiguration setInitialConnectAttempts(int initialConnectAttempts)
      Parameters:
      initialConnectAttempts - the initialConnectAttempts to set
    • getReconnectAttempts

      public int getReconnectAttempts()
    • setReconnectAttempts

      public BridgeConfiguration setReconnectAttempts(int reconnectAttempts)
      Parameters:
      reconnectAttempts - the reconnectAttempts to set
    • isUseDuplicateDetection

      public boolean isUseDuplicateDetection()
    • setUseDuplicateDetection

      public BridgeConfiguration setUseDuplicateDetection(boolean useDuplicateDetection)
      Parameters:
      useDuplicateDetection - the useDuplicateDetection to set
    • getConfirmationWindowSize

      public int getConfirmationWindowSize()
    • setConfirmationWindowSize

      public BridgeConfiguration setConfirmationWindowSize(int confirmationWindowSize)
      Parameters:
      confirmationWindowSize - the confirmationWindowSize to set
    • getProducerWindowSize

      public int getProducerWindowSize()
    • setProducerWindowSize

      public BridgeConfiguration setProducerWindowSize(int producerWindowSize)
      Parameters:
      producerWindowSize - the producerWindowSize to set
    • getClientFailureCheckPeriod

      public long getClientFailureCheckPeriod()
    • setClientFailureCheckPeriod

      public BridgeConfiguration setClientFailureCheckPeriod(long clientFailureCheckPeriod)
    • getMinLargeMessageSize

      public int getMinLargeMessageSize()
      Returns:
      the minLargeMessageSize
    • setMinLargeMessageSize

      public BridgeConfiguration setMinLargeMessageSize(int minLargeMessageSize)
    • getUser

      public String getUser()
    • setUser

      public BridgeConfiguration setUser(String user)
    • getPassword

      public String getPassword()
    • setPassword

      public BridgeConfiguration setPassword(String password)
    • getCallTimeout

      public long getCallTimeout()
      Returns:
      the callTimeout
    • getReconnectAttemptsOnSameNode

      public int getReconnectAttemptsOnSameNode()
    • setReconnectAttemptsOnSameNode

      public BridgeConfiguration setReconnectAttemptsOnSameNode(int reconnectAttemptsOnSameNode)
    • isConfigurationManaged

      public boolean isConfigurationManaged()
    • setConfigurationManaged

      public BridgeConfiguration setConfigurationManaged(boolean configurationManaged)
    • getRoutingType

      public org.apache.activemq.artemis.core.server.ComponentConfigurationRoutingType getRoutingType()
    • setRoutingType

      public BridgeConfiguration setRoutingType(org.apache.activemq.artemis.core.server.ComponentConfigurationRoutingType routingType)
    • getConcurrency

      public int getConcurrency()
      Returns:
      the bridge concurrency
    • setConcurrency

      public BridgeConfiguration setConcurrency(int concurrency)
      Parameters:
      concurrency - the bridge concurrency to set
    • getPendingAckTimeout

      public long getPendingAckTimeout()
      Returns:
      the bridge pending ack timeout
    • setPendingAckTimeout

      public BridgeConfiguration setPendingAckTimeout(long pendingAckTimeout)
      Parameters:
      pendingAckTimeout - the bridge pending ack timeout to set
    • getClientId

      public String getClientId()
      Returns:
      the bridge client ID
    • setClientId

      public BridgeConfiguration setClientId(String clientId)
      Parameters:
      clientId - the bridge clientId to set
    • setCallTimeout

      public BridgeConfiguration setCallTimeout(long callTimeout)
      At this point this is only changed on testcases The bridge shouldn't be sending blocking anyways
      Parameters:
      callTimeout - the callTimeout to set
    • toJSON

      public String toJSON()
      This method returns a JSON-formatted String representation of this BridgeConfiguration. It is a simple collection of key/value pairs. The keys used are referenced in set(String, String).
      Returns:
      a JSON-formatted String representation of this BridgeConfiguration
    • fromJSON

      public static BridgeConfiguration fromJSON(String jsonString)
      This method returns a BridgeConfiguration created from the JSON-formatted input String. The input should be a simple object of key/value pairs. Valid keys are referenced in set(String, String).
      Parameters:
      jsonString - json string
      Returns:
      the BridgeConfiguration created from the JSON-formatted input String
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object
    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class Object
    • getEncodeSize

      public int getEncodeSize()
    • encode

      public void encode(ActiveMQBuffer buffer)
    • decode

      public void decode(ActiveMQBuffer buffer)