public class NetworkBridgeConfiguration extends Object
Modifier and Type | Field and Description |
---|---|
protected List<ActiveMQDestination> |
dynamicallyIncludedDestinations |
protected List<ActiveMQDestination> |
excludedDestinations |
protected List<ActiveMQDestination> |
staticallyIncludedDestinations |
Constructor and Description |
---|
NetworkBridgeConfiguration() |
protected List<ActiveMQDestination> excludedDestinations
protected List<ActiveMQDestination> dynamicallyIncludedDestinations
protected List<ActiveMQDestination> staticallyIncludedDestinations
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 isSyncDurableSubs()
public void setSyncDurableSubs(boolean syncDurableSubs)
public 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 String getBrokerName()
public void setBrokerName(String brokerName)
brokerName
- the localBrokerName to setpublic int getNetworkTTL()
public void setNetworkTTL(int networkTTL)
networkTTL
- the networkTTL to setpublic String getPassword()
public void setPassword(String password)
password
- the password to setpublic int getPrefetchSize()
public void setPrefetchSize(int prefetchSize)
prefetchSize
- the prefetchSize to setpublic int getAdvisoryPrefetchSize()
public void setAdvisoryPrefetchSize(int advisoryPrefetchSize)
advisoryPrefetchSize
- public int getAdvisoryAckPercentage()
public void setAdvisoryAckPercentage(int advisoryAckPercentage)
advisoryAckPercentage
- the percentage of the advisory prefetch size
value that can be dispatched before an ack will be sent, defaults to 75
which means that when the number of received messages is greater than 75% of
the prefetch size an ack will be sent backpublic String getUserName()
public void setUserName(String userName)
userName
- the userName to setpublic String getDestinationFilter()
public void setDestinationFilter(String destinationFilter)
destinationFilter
- the destinationFilter to setpublic List<ActiveMQDestination> getExcludedDestinations()
public void setExcludedDestinations(List<ActiveMQDestination> excludedDestinations)
public List<ActiveMQDestination> getDynamicallyIncludedDestinations()
public void setDynamicallyIncludedDestinations(List<ActiveMQDestination> dynamicallyIncludedDestinations)
public List<ActiveMQDestination> getStaticallyIncludedDestinations()
public void setStaticallyIncludedDestinations(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 String getBrokerURL()
public void setBrokerURL(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)
public void setUseCompression(boolean useCompression)
useCompression
- True if the Network should enforce compression for messages sent.public boolean isUseCompression()
public boolean isAdvisoryForFailedForward()
public void setAdvisoryForFailedForward(boolean advisoryForFailedForward)
public void setConsumerTTL(int consumerTTL)
public int getConsumerTTL()
public void setMessageTTL(int messageTTL)
public int getMessageTTL()
public boolean isUseBrokerNamesAsIdSeed()
public void setUseBrokerNameAsIdSees(boolean val)
public boolean isGcDestinationViews()
public void setGcDestinationViews(boolean gcDestinationViews)
public long getGcSweepTime()
public void setGcSweepTime(long gcSweepTime)
public boolean isCheckDuplicateMessagesOnDuplex()
public void setCheckDuplicateMessagesOnDuplex(boolean checkDuplicateMessagesOnDuplex)
public boolean isUseVirtualDestSubs()
@Deprecated public boolean isUseVirtualDestSus()
public void setUseVirtualDestSubs(boolean useVirtualDestSubs)
Copyright © 2005–2017 The Apache Software Foundation. All rights reserved.