org.apache.activemq.network
Class NetworkBridgeConfiguration
java.lang.Object
org.apache.activemq.network.NetworkBridgeConfiguration
- Direct Known Subclasses:
- NetworkConnector
public class NetworkBridgeConfiguration
- extends java.lang.Object
Configuration for a NetworkBridge
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
NetworkBridgeConfiguration
public NetworkBridgeConfiguration()
isConduitSubscriptions
public boolean isConduitSubscriptions()
- Returns:
- the conduitSubscriptions
setConduitSubscriptions
public void setConduitSubscriptions(boolean conduitSubscriptions)
- Parameters:
conduitSubscriptions
- the conduitSubscriptions to set
isDynamicOnly
public boolean isDynamicOnly()
- Returns:
- the dynamicOnly
setDynamicOnly
public void setDynamicOnly(boolean dynamicOnly)
- Parameters:
dynamicOnly
- the dynamicOnly to set
isBridgeTempDestinations
public boolean isBridgeTempDestinations()
- Returns:
- the bridgeTempDestinations
setBridgeTempDestinations
public void setBridgeTempDestinations(boolean bridgeTempDestinations)
- Parameters:
bridgeTempDestinations
- the bridgeTempDestinations to set
isDecreaseNetworkConsumerPriority
public boolean isDecreaseNetworkConsumerPriority()
- Returns:
- the decreaseNetworkConsumerPriority
setDecreaseNetworkConsumerPriority
public void setDecreaseNetworkConsumerPriority(boolean decreaseNetworkConsumerPriority)
- Parameters:
decreaseNetworkConsumerPriority
- the
decreaseNetworkConsumerPriority to set
isDispatchAsync
public boolean isDispatchAsync()
- Returns:
- the dispatchAsync
setDispatchAsync
public void setDispatchAsync(boolean dispatchAsync)
- Parameters:
dispatchAsync
- the dispatchAsync to set
isDuplex
public boolean isDuplex()
- Returns:
- the duplex
setDuplex
public void setDuplex(boolean duplex)
- Parameters:
duplex
- the duplex to set
getBrokerName
public java.lang.String getBrokerName()
- Returns:
- the brokerName
setBrokerName
public void setBrokerName(java.lang.String brokerName)
- Parameters:
brokerName
- the localBrokerName to set
getNetworkTTL
public int getNetworkTTL()
- Returns:
- the networkTTL
setNetworkTTL
public void setNetworkTTL(int networkTTL)
- Parameters:
networkTTL
- the networkTTL to set
getPassword
public java.lang.String getPassword()
- Returns:
- the password
setPassword
public void setPassword(java.lang.String password)
- Parameters:
password
- the password to set
getPrefetchSize
public int getPrefetchSize()
- Returns:
- the prefetchSize
setPrefetchSize
public void setPrefetchSize(int prefetchSize)
- Parameters:
prefetchSize
- the prefetchSize to set
getUserName
public java.lang.String getUserName()
- Returns:
- the userName
setUserName
public void setUserName(java.lang.String userName)
- Parameters:
userName
- the userName to set
getDestinationFilter
public java.lang.String getDestinationFilter()
- Returns:
- the destinationFilter
setDestinationFilter
public void setDestinationFilter(java.lang.String destinationFilter)
- Parameters:
destinationFilter
- the destinationFilter to set
getName
public java.lang.String getName()
- Returns:
- the name
setName
public void setName(java.lang.String name)
- Parameters:
name
- the name to set
getExcludedDestinations
public java.util.List<ActiveMQDestination> getExcludedDestinations()
setExcludedDestinations
public void setExcludedDestinations(java.util.List<ActiveMQDestination> excludedDestinations)
getDynamicallyIncludedDestinations
public java.util.List<ActiveMQDestination> getDynamicallyIncludedDestinations()
setDynamicallyIncludedDestinations
public void setDynamicallyIncludedDestinations(java.util.List<ActiveMQDestination> dynamicallyIncludedDestinations)
getStaticallyIncludedDestinations
public java.util.List<ActiveMQDestination> getStaticallyIncludedDestinations()
setStaticallyIncludedDestinations
public void setStaticallyIncludedDestinations(java.util.List<ActiveMQDestination> staticallyIncludedDestinations)
isSuppressDuplicateQueueSubscriptions
public boolean isSuppressDuplicateQueueSubscriptions()
setSuppressDuplicateQueueSubscriptions
public void setSuppressDuplicateQueueSubscriptions(boolean val)
- Parameters:
val
- if true, duplicate network queue subscriptions (in a cyclic network) will be suppressed
isSuppressDuplicateTopicSubscriptions
public boolean isSuppressDuplicateTopicSubscriptions()
setSuppressDuplicateTopicSubscriptions
public void setSuppressDuplicateTopicSubscriptions(boolean val)
- Parameters:
val
- if true, duplicate network topic subscriptions (in a cyclic network) will be suppressed
getBrokerURL
public java.lang.String getBrokerURL()
- Returns:
- the brokerURL
setBrokerURL
public void setBrokerURL(java.lang.String brokerURL)
- Parameters:
brokerURL
- the brokerURL to set
isAlwaysSyncSend
public boolean isAlwaysSyncSend()
setAlwaysSyncSend
public void setAlwaysSyncSend(boolean alwaysSyncSend)
- Parameters:
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.
getConsumerPriorityBase
public int getConsumerPriorityBase()
setConsumerPriorityBase
public void setConsumerPriorityBase(int consumerPriorityBase)
- Parameters:
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.
isStaticBridge
public boolean isStaticBridge()
setStaticBridge
public void setStaticBridge(boolean staticBridge)
Copyright © 2005-2012. All Rights Reserved.