org.apache.activemq.network
Class NetworkBridgeConfiguration

java.lang.Object
  extended by org.apache.activemq.network.NetworkBridgeConfiguration
Direct Known Subclasses:
NetworkConnector

public class NetworkBridgeConfiguration
extends Object

Configuration for a NetworkBridge


Field Summary
protected  List<ActiveMQDestination> dynamicallyIncludedDestinations
           
protected  List<ActiveMQDestination> excludedDestinations
           
protected  List<ActiveMQDestination> staticallyIncludedDestinations
           
 
Constructor Summary
NetworkBridgeConfiguration()
           
 
Method Summary
 String getBrokerName()
           
 String getBrokerURL()
           
 int getConsumerPriorityBase()
           
 int getConsumerTTL()
           
 String getDestinationFilter()
           
 List<ActiveMQDestination> getDynamicallyIncludedDestinations()
           
 List<ActiveMQDestination> getExcludedDestinations()
           
 int getMessageTTL()
           
 String getName()
           
 int getNetworkTTL()
           
 String getPassword()
           
 int getPrefetchSize()
           
 List<ActiveMQDestination> getStaticallyIncludedDestinations()
           
 String getUserName()
           
 boolean isAdvisoryForFailedForward()
           
 boolean isAlwaysSyncSend()
           
 boolean isBridgeTempDestinations()
           
 boolean isConduitSubscriptions()
           
 boolean isDecreaseNetworkConsumerPriority()
           
 boolean isDispatchAsync()
           
 boolean isDuplex()
           
 boolean isDynamicOnly()
           
 boolean isStaticBridge()
           
 boolean isSuppressDuplicateQueueSubscriptions()
           
 boolean isSuppressDuplicateTopicSubscriptions()
           
 boolean isUseBrokerNamesAsIdSeed()
           
 boolean isUseCompression()
           
 void setAdvisoryForFailedForward(boolean advisoryForFailedForward)
           
 void setAlwaysSyncSend(boolean alwaysSyncSend)
           
 void setBridgeTempDestinations(boolean bridgeTempDestinations)
           
 void setBrokerName(String brokerName)
           
 void setBrokerURL(String brokerURL)
           
 void setConduitSubscriptions(boolean conduitSubscriptions)
           
 void setConsumerPriorityBase(int consumerPriorityBase)
           
 void setConsumerTTL(int consumerTTL)
           
 void setDecreaseNetworkConsumerPriority(boolean decreaseNetworkConsumerPriority)
           
 void setDestinationFilter(String destinationFilter)
           
 void setDispatchAsync(boolean dispatchAsync)
           
 void setDuplex(boolean duplex)
           
 void setDynamicallyIncludedDestinations(List<ActiveMQDestination> dynamicallyIncludedDestinations)
           
 void setDynamicOnly(boolean dynamicOnly)
           
 void setExcludedDestinations(List<ActiveMQDestination> excludedDestinations)
           
 void setMessageTTL(int messageTTL)
           
 void setName(String name)
           
 void setNetworkTTL(int networkTTL)
           
 void setPassword(String password)
           
 void setPrefetchSize(int prefetchSize)
           
 void setStaticallyIncludedDestinations(List<ActiveMQDestination> staticallyIncludedDestinations)
           
 void setStaticBridge(boolean staticBridge)
           
 void setSuppressDuplicateQueueSubscriptions(boolean val)
           
 void setSuppressDuplicateTopicSubscriptions(boolean val)
           
 void setUseBrokerNameAsIdSees(boolean val)
           
 void setUseCompression(boolean useCompression)
           
 void setUserName(String userName)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

excludedDestinations

protected List<ActiveMQDestination> excludedDestinations

dynamicallyIncludedDestinations

protected List<ActiveMQDestination> dynamicallyIncludedDestinations

staticallyIncludedDestinations

protected List<ActiveMQDestination> staticallyIncludedDestinations
Constructor Detail

NetworkBridgeConfiguration

public NetworkBridgeConfiguration()
Method Detail

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 String getBrokerName()
Returns:
the brokerName

setBrokerName

public void setBrokerName(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 String getPassword()
Returns:
the password

setPassword

public void setPassword(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 String getUserName()
Returns:
the userName

setUserName

public void setUserName(String userName)
Parameters:
userName - the userName to set

getDestinationFilter

public String getDestinationFilter()
Returns:
the destinationFilter

setDestinationFilter

public void setDestinationFilter(String destinationFilter)
Parameters:
destinationFilter - the destinationFilter to set

getName

public String getName()
Returns:
the name

setName

public void setName(String name)
Parameters:
name - the name to set

getExcludedDestinations

public List<ActiveMQDestination> getExcludedDestinations()

setExcludedDestinations

public void setExcludedDestinations(List<ActiveMQDestination> excludedDestinations)

getDynamicallyIncludedDestinations

public List<ActiveMQDestination> getDynamicallyIncludedDestinations()

setDynamicallyIncludedDestinations

public void setDynamicallyIncludedDestinations(List<ActiveMQDestination> dynamicallyIncludedDestinations)

getStaticallyIncludedDestinations

public List<ActiveMQDestination> getStaticallyIncludedDestinations()

setStaticallyIncludedDestinations

public void setStaticallyIncludedDestinations(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 String getBrokerURL()
Returns:
the brokerURL

setBrokerURL

public void setBrokerURL(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)

setUseCompression

public void setUseCompression(boolean useCompression)
Parameters:
useCompression - True if the Network should enforce compression for messages sent.

isUseCompression

public boolean isUseCompression()
Returns:
the useCompression setting, true if message will be compressed on send.

isAdvisoryForFailedForward

public boolean isAdvisoryForFailedForward()

setAdvisoryForFailedForward

public void setAdvisoryForFailedForward(boolean advisoryForFailedForward)

setConsumerTTL

public void setConsumerTTL(int consumerTTL)

getConsumerTTL

public int getConsumerTTL()

setMessageTTL

public void setMessageTTL(int messageTTL)

getMessageTTL

public int getMessageTTL()

isUseBrokerNamesAsIdSeed

public boolean isUseBrokerNamesAsIdSeed()

setUseBrokerNameAsIdSees

public void setUseBrokerNameAsIdSees(boolean val)


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.