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)
      Sets the name of this BridgeConfiguration. If the parentName is null then it is also set.
      Parameters:
      name - the name to use
      Returns:
      this BridgeConfiguration

    • getParentName

      public String getParentName()

    • setParentName

      public BridgeConfiguration setParentName(String parentName)

    • getQueueName

      public String getQueueName()

    • setQueueName

      public BridgeConfiguration setQueueName(String queueName)

    • getConnectionTTL

      public long getConnectionTTL()

    • setConnectionTTL

      public BridgeConfiguration setConnectionTTL(long connectionTTL)

    • getMaxRetryInterval

      public long getMaxRetryInterval()

    • setMaxRetryInterval

      public BridgeConfiguration setMaxRetryInterval(long maxRetryInterval)

    • getForwardingAddress

      public String getForwardingAddress()

    • setForwardingAddress

      public BridgeConfiguration setForwardingAddress(String forwardingAddress)

    • getFilterString

      public String getFilterString()

    • setFilterString

      public BridgeConfiguration setFilterString(String filterString)

    • getTransformerConfiguration

      public TransformerConfiguration getTransformerConfiguration()

    • setTransformerConfiguration

      public BridgeConfiguration setTransformerConfiguration(TransformerConfiguration transformerConfiguration)

    • getStaticConnectors

      public List<String> getStaticConnectors()

    • setStaticConnectors

      public BridgeConfiguration setStaticConnectors(List<String> staticConnectors)

    • getDiscoveryGroupName

      public String getDiscoveryGroupName()

    • setDiscoveryGroupName

      public BridgeConfiguration setDiscoveryGroupName(String discoveryGroupName)

    • isHA

      public boolean isHA()

    • setHA

      public BridgeConfiguration setHA(boolean ha)

    • getRetryInterval

      public long getRetryInterval()

    • setRetryInterval

      public BridgeConfiguration setRetryInterval(long retryInterval)

    • getRetryIntervalMultiplier

      public double getRetryIntervalMultiplier()

    • setRetryIntervalMultiplier

      public BridgeConfiguration setRetryIntervalMultiplier(double retryIntervalMultiplier)

    • getInitialConnectAttempts

      public int getInitialConnectAttempts()

    • setInitialConnectAttempts

      public BridgeConfiguration setInitialConnectAttempts(int initialConnectAttempts)

    • getReconnectAttempts

      public int getReconnectAttempts()

    • setReconnectAttempts

      public BridgeConfiguration setReconnectAttempts(int reconnectAttempts)

    • isUseDuplicateDetection

      public boolean isUseDuplicateDetection()

    • setUseDuplicateDetection

      public BridgeConfiguration setUseDuplicateDetection(boolean useDuplicateDetection)

    • getConfirmationWindowSize

      public int getConfirmationWindowSize()

    • setConfirmationWindowSize

      public BridgeConfiguration setConfirmationWindowSize(int confirmationWindowSize)

    • getProducerWindowSize

      public int getProducerWindowSize()

    • setProducerWindowSize

      public BridgeConfiguration setProducerWindowSize(int producerWindowSize)

    • getClientFailureCheckPeriod

      public long getClientFailureCheckPeriod()

    • setClientFailureCheckPeriod

      public BridgeConfiguration setClientFailureCheckPeriod(long clientFailureCheckPeriod)

    • getMinLargeMessageSize

      public int getMinLargeMessageSize()

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

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

    • setConcurrency

      public BridgeConfiguration setConcurrency(int concurrency)

    • getPendingAckTimeout

      public long getPendingAckTimeout()

    • setPendingAckTimeout

      public BridgeConfiguration setPendingAckTimeout(long pendingAckTimeout)

    • getClientId

      public String getClientId()

    • setClientId

      public BridgeConfiguration setClientId(String clientId)

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