org.apache.activemq.network
public class NetworkBridgeConfiguration extends java.lang.Object
Constructor and Description |
---|
NetworkBridgeConfiguration() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getBrokerName() |
java.lang.String |
getBrokerURL() |
int |
getConsumerPriorityBase() |
java.lang.String |
getDestinationFilter() |
java.util.List<ActiveMQDestination> |
getDynamicallyIncludedDestinations() |
java.util.List<ActiveMQDestination> |
getExcludedDestinations() |
java.lang.String |
getName() |
int |
getNetworkTTL() |
java.lang.String |
getPassword() |
int |
getPrefetchSize() |
java.util.List<ActiveMQDestination> |
getStaticallyIncludedDestinations() |
java.lang.String |
getUserName() |
boolean |
isAlwaysSyncSend() |
boolean |
isBridgeTempDestinations() |
boolean |
isConduitSubscriptions() |
boolean |
isDecreaseNetworkConsumerPriority() |
boolean |
isDispatchAsync() |
boolean |
isDuplex() |
boolean |
isDynamicOnly() |
boolean |
isStaticBridge() |
boolean |
isSuppressDuplicateQueueSubscriptions() |
boolean |
isSuppressDuplicateTopicSubscriptions() |
void |
setAlwaysSyncSend(boolean alwaysSyncSend) |
void |
setBridgeTempDestinations(boolean bridgeTempDestinations) |
void |
setBrokerName(java.lang.String brokerName) |
void |
setBrokerURL(java.lang.String brokerURL) |
void |
setConduitSubscriptions(boolean conduitSubscriptions) |
void |
setConsumerPriorityBase(int consumerPriorityBase) |
void |
setDecreaseNetworkConsumerPriority(boolean decreaseNetworkConsumerPriority) |
void |
setDestinationFilter(java.lang.String destinationFilter) |
void |
setDispatchAsync(boolean dispatchAsync) |
void |
setDuplex(boolean duplex) |
void |
setDynamicallyIncludedDestinations(java.util.List<ActiveMQDestination> dynamicallyIncludedDestinations) |
void |
setDynamicOnly(boolean dynamicOnly) |
void |
setExcludedDestinations(java.util.List<ActiveMQDestination> excludedDestinations) |
void |
setName(java.lang.String name) |
void |
setNetworkTTL(int networkTTL) |
void |
setPassword(java.lang.String password) |
void |
setPrefetchSize(int prefetchSize) |
void |
setStaticallyIncludedDestinations(java.util.List<ActiveMQDestination> staticallyIncludedDestinations) |
void |
setStaticBridge(boolean staticBridge) |
void |
setSuppressDuplicateQueueSubscriptions(boolean val) |
void |
setSuppressDuplicateTopicSubscriptions(boolean val) |
void |
setUserName(java.lang.String userName) |
public NetworkBridgeConfiguration()
public boolean isConduitSubscriptions()
public void setConduitSubscriptions(boolean conduitSubscriptions)
conduitSubscriptions
- the conduitSubscriptions to setpublic boolean isDynamicOnly()
public void setDynamicOnly(boolean dynamicOnly)
dynamicOnly
- the dynamicOnly to setpublic boolean isBridgeTempDestinations()
public void setBridgeTempDestinations(boolean bridgeTempDestinations)
bridgeTempDestinations
- the bridgeTempDestinations to setpublic boolean isDecreaseNetworkConsumerPriority()
public void setDecreaseNetworkConsumerPriority(boolean decreaseNetworkConsumerPriority)
decreaseNetworkConsumerPriority
- the
decreaseNetworkConsumerPriority to setpublic boolean isDispatchAsync()
public void setDispatchAsync(boolean dispatchAsync)
dispatchAsync
- the dispatchAsync to setpublic boolean isDuplex()
public void setDuplex(boolean duplex)
duplex
- the duplex to setpublic java.lang.String getBrokerName()
public void setBrokerName(java.lang.String brokerName)
brokerName
- the localBrokerName to setpublic int getNetworkTTL()
public void setNetworkTTL(int networkTTL)
networkTTL
- the networkTTL to setpublic java.lang.String getPassword()
public void setPassword(java.lang.String password)
password
- the password to setpublic int getPrefetchSize()
public void setPrefetchSize(int prefetchSize)
prefetchSize
- the prefetchSize to setpublic java.lang.String getUserName()
public void setUserName(java.lang.String userName)
userName
- the userName to setpublic java.lang.String getDestinationFilter()
public void setDestinationFilter(java.lang.String destinationFilter)
destinationFilter
- the destinationFilter to setpublic java.lang.String getName()
public void setName(java.lang.String name)
name
- the name to setpublic java.util.List<ActiveMQDestination> getExcludedDestinations()
public void setExcludedDestinations(java.util.List<ActiveMQDestination> excludedDestinations)
public java.util.List<ActiveMQDestination> getDynamicallyIncludedDestinations()
public void setDynamicallyIncludedDestinations(java.util.List<ActiveMQDestination> dynamicallyIncludedDestinations)
public java.util.List<ActiveMQDestination> getStaticallyIncludedDestinations()
public void setStaticallyIncludedDestinations(java.util.List<ActiveMQDestination> staticallyIncludedDestinations)
public boolean isSuppressDuplicateQueueSubscriptions()
public void setSuppressDuplicateQueueSubscriptions(boolean val)
val
- if true, duplicate network queue subscriptions (in a cyclic network) will be suppressedpublic boolean isSuppressDuplicateTopicSubscriptions()
public void setSuppressDuplicateTopicSubscriptions(boolean val)
val
- if true, duplicate network topic subscriptions (in a cyclic network) will be suppressedpublic java.lang.String getBrokerURL()
public void setBrokerURL(java.lang.String brokerURL)
brokerURL
- the brokerURL to setpublic boolean isAlwaysSyncSend()
public void setAlwaysSyncSend(boolean alwaysSyncSend)
alwaysSyncSend
- when true, both persistent and non persistent
messages will be sent using a request. When false, non persistent messages
are acked once the oneway send succeeds, which can potentially lead to
message loss.
Using an async request, allows multiple outstanding requests. This ensures
that a bridge need not block all sending when the remote broker needs to
flow control a single destination.public int getConsumerPriorityBase()
public void setConsumerPriorityBase(int consumerPriorityBase)
consumerPriorityBase
- , default -5. Sets the starting priority
for consumers. This base value will be decremented by the length of the
broker path when decreaseNetworkConsumerPriority is set.public boolean isStaticBridge()
public void setStaticBridge(boolean staticBridge)
Copyright © 2005-2014. All Rights Reserved.