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

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<ActiveMQDestination>	dynamicallyIncludedDestinations
protected java.util.List<ActiveMQDestination>	excludedDestinations
protected java.util.List<ActiveMQDestination>	staticallyIncludedDestinations

Constructor Summary

Constructors

Constructor and Description
NetworkBridgeConfiguration()

Method Summary

Methods

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	isAdvisoryForFailedForward()
boolean	isAlwaysSyncSend()
boolean	isBridgeTempDestinations()
boolean	isConduitSubscriptions()
boolean	isDecreaseNetworkConsumerPriority()
boolean	isDispatchAsync()
boolean	isDuplex()
boolean	isDynamicOnly()
boolean	isStaticBridge()
boolean	isSuppressDuplicateQueueSubscriptions()
boolean	isSuppressDuplicateTopicSubscriptions()
boolean	isUseCompression()
void	setAdvisoryForFailedForward(boolean advisoryForFailedForward)
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	setUseCompression(boolean useCompression)
void	setUserName(java.lang.String userName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

excludedDestinations

protected java.util.List<ActiveMQDestination> excludedDestinations

dynamicallyIncludedDestinations

protected java.util.List<ActiveMQDestination> dynamicallyIncludedDestinations

staticallyIncludedDestinations

protected java.util.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 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)

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)