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:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static String
CALL_TIMEOUT
static String
CLIENT_FAILURE_CHECK_PERIOD
static String
CONCURRENCY
static String
CONFIGURATION_MANAGED
static String
CONFIRMATION_WINDOW_SIZE
static String
CONNECTION_TTL
static String
DISCOVERY_GROUP_NAME
static String
FILTER_STRING
static String
FORWARDING_ADDRESS
static String
HA
static String
INITIAL_CONNECT_ATTEMPTS
static String
MAX_RETRY_INTERVAL
static String
MIN_LARGE_MESSAGE_SIZE
static String
NAME
static String
PASSWORD
static String
PRODUCER_WINDOW_SIZE
static String
QUEUE_NAME
static String
RECONNECT_ATTEMPTS
static String
RECONNECT_ATTEMPTS_ON_SAME_NODE
static String
RETRY_INTERVAL
static String
RETRY_INTERVAL_MULTIPLIER
static String
ROUTING_TYPE
static String
STATIC_CONNECTORS
static String
TRANSFORMER_CONFIGURATION
static String
USE_DUPLICATE_DETECTION
static String
USER
-
Constructor Summary
Constructors Constructor Description BridgeConfiguration()
BridgeConfiguration(String name)
BridgeConfiguration(BridgeConfiguration other)
-
Method Summary
-
-
-
Field Detail
-
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
-
-
Constructor Detail
-
BridgeConfiguration
public BridgeConfiguration()
-
BridgeConfiguration
public BridgeConfiguration(BridgeConfiguration other)
-
BridgeConfiguration
public BridgeConfiguration(String name)
-
-
Method Detail
-
set
public BridgeConfiguration set(String key, String value)
Set the value of a parameter based on its "key"String
. Valid key names and correspondingstatic
final
are:- name:
NAME
- queue-name:
QUEUE_NAME
- forwarding-address:
FORWARDING_ADDRESS
- filter-string:
FILTER_STRING
- static-connectors:
STATIC_CONNECTORS
- discovery-group-name:
DISCOVERY_GROUP_NAME
- ha:
HA
- transformer-configuration:
TRANSFORMER_CONFIGURATION
- retry-interval:
RETRY_INTERVAL
- RETRY-interval-multiplier:
RETRY_INTERVAL_MULTIPLIER
- initial-connect-attempts:
INITIAL_CONNECT_ATTEMPTS
- reconnect-attempts:
RECONNECT_ATTEMPTS
- reconnect-attempts-on-same-node:
RECONNECT_ATTEMPTS_ON_SAME_NODE
- use-duplicate-detection:
USE_DUPLICATE_DETECTION
- confirmation-window-size:
CONFIRMATION_WINDOW_SIZE
- producer-window-size:
PRODUCER_WINDOW_SIZE
- client-failure-check-period:
CLIENT_FAILURE_CHECK_PERIOD
- user:
USER
- password:
PASSWORD
- connection-ttl:
CONNECTION_TTL
- max-retry-interval:
MAX_RETRY_INTERVAL
- min-large-message-size:
MIN_LARGE_MESSAGE_SIZE
- call-timeout:
CALL_TIMEOUT
- routing-type:
ROUTING_TYPE
- concurrency:
CONCURRENCY
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" theString
"TRUE" will be converted to theBoolean
true
.- Parameters:
key
- the key to set to the valuevalue
- the value to set for the key- Returns:
- this
BridgeConfiguration
- name:
-
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
-
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
-
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-formattedString
representation of thisBridgeConfiguration
. It is a simple collection of key/value pairs. The keys used are referenced inset(String, String)
.- Returns:
- a JSON-formatted
String
representation of thisBridgeConfiguration
-
fromJSON
public static BridgeConfiguration fromJSON(String jsonString)
This method returns aBridgeConfiguration
created from the JSON-formatted inputString
. The input should be a simple object of key/value pairs. Valid keys are referenced inset(String, String)
.- Parameters:
jsonString
- json string- Returns:
- the
BridgeConfiguration
created from the JSON-formatted inputString
-
getEncodeSize
public int getEncodeSize()
-
encode
public void encode(ActiveMQBuffer buffer)
-
decode
public void decode(ActiveMQBuffer buffer)
-
-