public class Bridge<T extends Bridge<T>> extends Object
Modifier and Type | Method and Description |
---|---|
void |
addPropertyChangeListener(PropertyChangeListener listener)
Adds a property change listener
|
Long |
checkPeriod()
The period (in milliseconds) between client failure check.
|
T |
checkPeriod(Long value)
The period (in milliseconds) between client failure check.
|
Integer |
confirmationWindowSize()
The confirmation-window-size to use for the connection used to forward
messages to the target node.
|
T |
confirmationWindowSize(Integer value)
The confirmation-window-size to use for the connection used to forward
messages to the target node.
|
Long |
connectionTtl()
The maximum time (in milliseconds) for which the connections used by the
bridges are considered alive (in the absence of heartbeat).
|
T |
connectionTtl(Long value)
The maximum time (in milliseconds) for which the connections used by the
bridges are considered alive (in the absence of heartbeat).
|
Map |
credentialReference()
Credential (from Credential Store) to authenticate the bridge
|
T |
credentialReference(Map value)
Credential (from Credential Store) to authenticate the bridge
|
T |
credentialReference(String key,
Object value)
Credential (from Credential Store) to authenticate the bridge
|
String |
discoveryGroup()
The name of the discovery group used by this bridge.
|
T |
discoveryGroup(String value)
The name of the discovery group used by this bridge.
|
String |
filter()
An optional filter string.
|
T |
filter(String value)
An optional filter string.
|
String |
forwardingAddress()
The address on the target server that the message will be forwarded to.
|
T |
forwardingAddress(String value)
The address on the target server that the message will be forwarded to.
|
String |
getKey() |
Boolean |
ha()
Whether or not this bridge should support high availability.
|
T |
ha(Boolean value)
Whether or not this bridge should support high availability.
|
Integer |
initialConnectAttempts()
The number of attempts to connect initially with this bridge.
|
T |
initialConnectAttempts(Integer value)
The number of attempts to connect initially with this bridge.
|
Long |
maxRetryInterval()
The maximum interval of time used to retry connections
|
T |
maxRetryInterval(Long value)
The maximum interval of time used to retry connections
|
Integer |
minLargeMessageSize()
The minimum size (in bytes) for a message before it is considered as a
large message.
|
T |
minLargeMessageSize(Integer value)
The minimum size (in bytes) for a message before it is considered as a
large message.
|
String |
password()
The password to use when creating the bridge connection to the remote
server.
|
T |
password(String value)
The password to use when creating the bridge connection to the remote
server.
|
Integer |
producerWindowSize()
Producer flow control size on the bridge.
|
T |
producerWindowSize(Integer value)
Producer flow control size on the bridge.
|
String |
queueName()
The unique name of the local queue that the bridge consumes from.
|
T |
queueName(String value)
The unique name of the local queue that the bridge consumes from.
|
Integer |
reconnectAttempts()
The total number of reconnect attempts the bridge will make before giving
up and shutting down.
|
T |
reconnectAttempts(Integer value)
The total number of reconnect attempts the bridge will make before giving
up and shutting down.
|
Integer |
reconnectAttemptsOnSameNode()
The total number of reconnect attempts on the same node the bridge will
make before giving up and shutting down.
|
T |
reconnectAttemptsOnSameNode(Integer value)
The total number of reconnect attempts on the same node the bridge will
make before giving up and shutting down.
|
void |
removePropertyChangeListener(PropertyChangeListener listener)
Removes a property change listener
|
Long |
retryInterval()
The period in milliseconds between subsequent reconnection attempts, if
the connection to the target server has failed.
|
T |
retryInterval(Long value)
The period in milliseconds between subsequent reconnection attempts, if
the connection to the target server has failed.
|
BigDecimal |
retryIntervalMultiplier()
A multiplier to apply to the time since the last retry to compute the
time to the next retry.
|
T |
retryIntervalMultiplier(BigDecimal value)
A multiplier to apply to the time since the last retry to compute the
time to the next retry.
|
Boolean |
started()
Whether the bridge is started.
|
T |
started(Boolean value)
Whether the bridge is started.
|
T |
staticConnector(String value)
A list of names of statically defined connectors used by this bridge.
|
List<String> |
staticConnectors()
A list of names of statically defined connectors used by this bridge.
|
T |
staticConnectors(List<String> value)
A list of names of statically defined connectors used by this bridge.
|
T |
staticConnectors(String... args)
A list of names of statically defined connectors used by this bridge.
|
String |
transformerClassName()
The name of a user-defined class which implements the
org.apache.activemq.artemis.core.server.cluster.Transformer interface.
|
T |
transformerClassName(String value)
The name of a user-defined class which implements the
org.apache.activemq.artemis.core.server.cluster.Transformer interface.
|
Boolean |
useDuplicateDetection()
Whether the bridge will automatically insert a duplicate id property into
each message that it forwards.
|
T |
useDuplicateDetection(Boolean value)
Whether the bridge will automatically insert a duplicate id property into
each message that it forwards.
|
String |
user()
The user name to use when creating the bridge connection to the remote
server.
|
T |
user(String value)
The user name to use when creating the bridge connection to the remote
server.
|
public Bridge(String key)
public String getKey()
public void addPropertyChangeListener(PropertyChangeListener listener)
public void removePropertyChangeListener(PropertyChangeListener listener)
public Long checkPeriod()
public T checkPeriod(Long value)
public Integer confirmationWindowSize()
public T confirmationWindowSize(Integer value)
public Long connectionTtl()
public T connectionTtl(Long value)
public Map credentialReference()
public T credentialReference(Map value)
public T credentialReference(String key, Object value)
public String discoveryGroup()
public T discoveryGroup(String value)
public String filter()
public T filter(String value)
public String forwardingAddress()
public T forwardingAddress(String value)
public Boolean ha()
public T ha(Boolean value)
public Integer initialConnectAttempts()
public T initialConnectAttempts(Integer value)
public Long maxRetryInterval()
public T maxRetryInterval(Long value)
public Integer minLargeMessageSize()
public T minLargeMessageSize(Integer value)
public String password()
public T password(String value)
public Integer producerWindowSize()
public T producerWindowSize(Integer value)
public String queueName()
public T queueName(String value)
public Integer reconnectAttempts()
public T reconnectAttempts(Integer value)
public Integer reconnectAttemptsOnSameNode()
public T reconnectAttemptsOnSameNode(Integer value)
public Long retryInterval()
public T retryInterval(Long value)
public BigDecimal retryIntervalMultiplier()
public T retryIntervalMultiplier(BigDecimal value)
public Boolean started()
public List<String> staticConnectors()
public T staticConnectors(List<String> value)
public T staticConnector(String value)
public T staticConnectors(String... args)
public String transformerClassName()
public T transformerClassName(String value)
public Boolean useDuplicateDetection()
public T useDuplicateDetection(Boolean value)
public String user()
Copyright © 2018 JBoss by Red Hat. All rights reserved.