Class BridgeConfiguration
java.lang.Object
org.apache.activemq.artemis.core.config.BridgeConfiguration
- All Implemented Interfaces:
Serializable
- See Also:
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
static String
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
decode
(ActiveMQBuffer buffer) void
encode
(ActiveMQBuffer buffer) boolean
static BridgeConfiguration
This method returns aBridgeConfiguration
created from the JSON-formatted inputString
.long
long
int
int
long
int
int
long
int
getName()
long
int
int
int
long
double
org.apache.activemq.artemis.core.server.ComponentConfigurationRoutingType
getUser()
int
hashCode()
boolean
boolean
isHA()
boolean
Set the value of a parameter based on its "key"String
.setCallTimeout
(long callTimeout) At this point this is only changed on testcases The bridge shouldn't be sending blocking anywayssetClientFailureCheckPeriod
(long clientFailureCheckPeriod) setClientId
(String clientId) setConcurrency
(int concurrency) setConfigurationManaged
(boolean configurationManaged) setConfirmationWindowSize
(int confirmationWindowSize) setConnectionTTL
(long connectionTTL) setDiscoveryGroupName
(String discoveryGroupName) setFilterString
(String filterString) setForwardingAddress
(String forwardingAddress) setHA
(boolean ha) setInitialConnectAttempts
(int initialConnectAttempts) setMaxRetryInterval
(long maxRetryInterval) setMinLargeMessageSize
(int minLargeMessageSize) setParentName
(String parentName) setPassword
(String password) setPendingAckTimeout
(long pendingAckTimeout) setProducerWindowSize
(int producerWindowSize) setQueueName
(String queueName) setReconnectAttempts
(int reconnectAttempts) setReconnectAttemptsOnSameNode
(int reconnectAttemptsOnSameNode) setRetryInterval
(long retryInterval) setRetryIntervalMultiplier
(double retryIntervalMultiplier) setRoutingType
(org.apache.activemq.artemis.core.server.ComponentConfigurationRoutingType routingType) setStaticConnectors
(List<String> staticConnectors) setTransformerConfiguration
(TransformerConfiguration transformerConfiguration) setUseDuplicateDetection
(boolean useDuplicateDetection) toJSON()
This method returns a JSON-formattedString
representation of thisBridgeConfiguration
.
-
Field Details
-
NAME
-
QUEUE_NAME
-
FORWARDING_ADDRESS
-
FILTER_STRING
-
STATIC_CONNECTORS
-
DISCOVERY_GROUP_NAME
-
HA
-
TRANSFORMER_CONFIGURATION
-
RETRY_INTERVAL
-
RETRY_INTERVAL_MULTIPLIER
-
INITIAL_CONNECT_ATTEMPTS
-
RECONNECT_ATTEMPTS
-
RECONNECT_ATTEMPTS_ON_SAME_NODE
-
USE_DUPLICATE_DETECTION
-
CONFIRMATION_WINDOW_SIZE
-
PRODUCER_WINDOW_SIZE
-
CLIENT_FAILURE_CHECK_PERIOD
-
USER
-
PASSWORD
-
CONNECTION_TTL
-
MAX_RETRY_INTERVAL
-
MIN_LARGE_MESSAGE_SIZE
-
CALL_TIMEOUT
-
ROUTING_TYPE
-
CONCURRENCY
-
CONFIGURATION_MANAGED
-
PENDING_ACK_TIMEOUT
-
CLIENT_ID
-
-
Constructor Details
-
BridgeConfiguration
public BridgeConfiguration() -
BridgeConfiguration
-
BridgeConfiguration
-
-
Method Details
-
set
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
- client-id:
CLIENT_ID
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
-
setName
- Parameters:
name
- the name to set
-
getParentName
-
setParentName
-
getQueueName
-
setQueueName
- Parameters:
queueName
- the queueName to set
-
getConnectionTTL
public long getConnectionTTL()- Returns:
- the connectionTTL
-
setConnectionTTL
-
getMaxRetryInterval
public long getMaxRetryInterval()- Returns:
- the maxRetryInterval
-
setMaxRetryInterval
-
getForwardingAddress
-
setForwardingAddress
- Parameters:
forwardingAddress
- the forwardingAddress to set
-
getFilterString
-
setFilterString
- Parameters:
filterString
- the filterString to set
-
getTransformerConfiguration
-
setTransformerConfiguration
public BridgeConfiguration setTransformerConfiguration(TransformerConfiguration transformerConfiguration) - Parameters:
transformerConfiguration
- the transformerConfiguration to set
-
getStaticConnectors
-
setStaticConnectors
- Parameters:
staticConnectors
- the staticConnectors to set
-
getDiscoveryGroupName
-
setDiscoveryGroupName
- Parameters:
discoveryGroupName
- the discoveryGroupName to set
-
isHA
public boolean isHA() -
setHA
- Parameters:
ha
- is the bridge supporting HA?
-
getRetryInterval
public long getRetryInterval() -
setRetryInterval
- Parameters:
retryInterval
- the retryInterval to set
-
getRetryIntervalMultiplier
public double getRetryIntervalMultiplier() -
setRetryIntervalMultiplier
- Parameters:
retryIntervalMultiplier
- the retryIntervalMultiplier to set
-
getInitialConnectAttempts
public int getInitialConnectAttempts() -
setInitialConnectAttempts
- Parameters:
initialConnectAttempts
- the initialConnectAttempts to set
-
getReconnectAttempts
public int getReconnectAttempts() -
setReconnectAttempts
- Parameters:
reconnectAttempts
- the reconnectAttempts to set
-
isUseDuplicateDetection
public boolean isUseDuplicateDetection() -
setUseDuplicateDetection
- Parameters:
useDuplicateDetection
- the useDuplicateDetection to set
-
getConfirmationWindowSize
public int getConfirmationWindowSize() -
setConfirmationWindowSize
- Parameters:
confirmationWindowSize
- the confirmationWindowSize to set
-
getProducerWindowSize
public int getProducerWindowSize() -
setProducerWindowSize
- Parameters:
producerWindowSize
- the producerWindowSize to set
-
getClientFailureCheckPeriod
public long getClientFailureCheckPeriod() -
setClientFailureCheckPeriod
-
getMinLargeMessageSize
public int getMinLargeMessageSize()- Returns:
- the minLargeMessageSize
-
setMinLargeMessageSize
-
getUser
-
setUser
-
getPassword
-
setPassword
-
getCallTimeout
public long getCallTimeout()- Returns:
- the callTimeout
-
getReconnectAttemptsOnSameNode
public int getReconnectAttemptsOnSameNode() -
setReconnectAttemptsOnSameNode
-
isConfigurationManaged
public boolean isConfigurationManaged() -
setConfigurationManaged
-
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
- Parameters:
concurrency
- the bridge concurrency to set
-
getPendingAckTimeout
public long getPendingAckTimeout()- Returns:
- the bridge pending ack timeout
-
setPendingAckTimeout
- Parameters:
pendingAckTimeout
- the bridge pending ack timeout to set
-
getClientId
- Returns:
- the bridge client ID
-
setClientId
- Parameters:
clientId
- the bridge clientId to set
-
setCallTimeout
At this point this is only changed on testcases The bridge shouldn't be sending blocking anyways- Parameters:
callTimeout
- the callTimeout to set
-
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
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
-
hashCode
public int hashCode() -
equals
-
getEncodeSize
public int getEncodeSize() -
encode
-
decode
-