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) Sets the name of thisBridgeConfiguration
.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
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
Sets the name of thisBridgeConfiguration
. If theparentName
isnull
then it is also set.- Parameters:
name
- the name to use- Returns:
- this
BridgeConfiguration
-
getParentName
-
setParentName
-
getQueueName
-
setQueueName
-
getConnectionTTL
public long getConnectionTTL() -
setConnectionTTL
-
getMaxRetryInterval
public long getMaxRetryInterval() -
setMaxRetryInterval
-
getForwardingAddress
-
setForwardingAddress
-
getFilterString
-
setFilterString
-
getTransformerConfiguration
-
setTransformerConfiguration
public BridgeConfiguration setTransformerConfiguration(TransformerConfiguration transformerConfiguration) -
getStaticConnectors
-
setStaticConnectors
-
getDiscoveryGroupName
-
setDiscoveryGroupName
-
isHA
public boolean isHA() -
setHA
-
getRetryInterval
public long getRetryInterval() -
setRetryInterval
-
getRetryIntervalMultiplier
public double getRetryIntervalMultiplier() -
setRetryIntervalMultiplier
-
getInitialConnectAttempts
public int getInitialConnectAttempts() -
setInitialConnectAttempts
-
getReconnectAttempts
public int getReconnectAttempts() -
setReconnectAttempts
-
isUseDuplicateDetection
public boolean isUseDuplicateDetection() -
setUseDuplicateDetection
-
getConfirmationWindowSize
public int getConfirmationWindowSize() -
setConfirmationWindowSize
-
getProducerWindowSize
public int getProducerWindowSize() -
setProducerWindowSize
-
getClientFailureCheckPeriod
public long getClientFailureCheckPeriod() -
setClientFailureCheckPeriod
-
getMinLargeMessageSize
public int getMinLargeMessageSize() -
setMinLargeMessageSize
-
getUser
-
setUser
-
getPassword
-
setPassword
-
getCallTimeout
public long getCallTimeout() -
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() -
setConcurrency
-
getPendingAckTimeout
public long getPendingAckTimeout() -
setPendingAckTimeout
-
getClientId
-
setClientId
-
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
-