org.apache.activemq.network
Class NetworkConnector
java.lang.Object
org.apache.activemq.util.ServiceSupport
org.apache.activemq.network.NetworkConnector
- All Implemented Interfaces:
- Service
- Direct Known Subclasses:
- DiscoveryNetworkConnector, MulticastNetworkConnector
public abstract class NetworkConnector
- extends ServiceSupport
- Version:
- $Revision$
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
log
protected static final org.apache.commons.logging.Log log
localURI
protected java.net.URI localURI
failover
protected boolean failover
dynamicOnly
protected boolean dynamicOnly
conduitSubscriptions
protected boolean conduitSubscriptions
connectionFilter
protected ConnectionFilter connectionFilter
NetworkConnector
public NetworkConnector()
NetworkConnector
public NetworkConnector(java.net.URI localURI)
getLocalUri
public java.net.URI getLocalUri()
throws java.net.URISyntaxException
- Throws:
java.net.URISyntaxException
setLocalUri
public void setLocalUri(java.net.URI localURI)
getName
public java.lang.String getName()
- Returns:
- Returns the name.
setName
public void setName(java.lang.String name)
- Parameters:
name
- The name to set.
getBrokerName
public java.lang.String getBrokerName()
setBrokerName
public void setBrokerName(java.lang.String brokerName)
- Parameters:
brokerName
- The brokerName to set.
getDurableDestinations
public java.util.Set getDurableDestinations()
- Returns:
- Returns the durableDestinations.
setDurableDestinations
public void setDurableDestinations(java.util.Set durableDestinations)
- Parameters:
durableDestinations
- The durableDestinations to set.
isDynamicOnly
public boolean isDynamicOnly()
- Returns:
- Returns the dynamicOnly.
setDynamicOnly
public void setDynamicOnly(boolean dynamicOnly)
- Parameters:
dynamicOnly
- The dynamicOnly to set.
isConduitSubscriptions
public boolean isConduitSubscriptions()
- Returns:
- Returns the conduitSubscriptions.
setConduitSubscriptions
public void setConduitSubscriptions(boolean conduitSubscriptions)
- Parameters:
conduitSubscriptions
- The conduitSubscriptions to set.
isDecreaseNetworkConsumerPriority
public boolean isDecreaseNetworkConsumerPriority()
- Returns:
- Returns the decreaseNetworkConsumerPriority.
setDecreaseNetworkConsumerPriority
public void setDecreaseNetworkConsumerPriority(boolean decreaseNetworkConsumerPriority)
- Parameters:
decreaseNetworkConsumerPriority
- The decreaseNetworkConsumerPriority to set.
getNetworkTTL
public int getNetworkTTL()
- Returns:
- Returns the networkTTL.
setNetworkTTL
public void setNetworkTTL(int networkTTL)
- Parameters:
networkTTL
- The networkTTL to set.
getExcludedDestinations
public java.util.List getExcludedDestinations()
- Returns:
- Returns the excludedDestinations.
setExcludedDestinations
public void setExcludedDestinations(java.util.List exludedDestinations)
- Parameters:
excludedDestinations
- The excludedDestinations to set.
addExcludedDestination
public void addExcludedDestination(ActiveMQDestination destiantion)
getStaticallyIncludedDestinations
public java.util.List getStaticallyIncludedDestinations()
- Returns:
- Returns the staticallyIncludedDestinations.
setStaticallyIncludedDestinations
public void setStaticallyIncludedDestinations(java.util.List staticallyIncludedDestinations)
- Parameters:
staticallyIncludedDestinations
- The staticallyIncludedDestinations to set.
addStaticallyIncludedDestination
public void addStaticallyIncludedDestination(ActiveMQDestination destiantion)
getDynamicallyIncludedDestinations
public java.util.List getDynamicallyIncludedDestinations()
- Returns:
- Returns the dynamicallyIncludedDestinations.
setDynamicallyIncludedDestinations
public void setDynamicallyIncludedDestinations(java.util.List dynamicallyIncludedDestinations)
- Parameters:
dynamicallyIncludedDestinations
- The dynamicallyIncludedDestinations to set.
addDynamicallyIncludedDestination
public void addDynamicallyIncludedDestination(ActiveMQDestination destiantion)
configureBridge
protected Bridge configureBridge(DemandForwardingBridgeSupport result)
createName
protected abstract java.lang.String createName()
doStart
protected void doStart()
throws java.lang.Exception
- Specified by:
doStart
in class ServiceSupport
- Throws:
java.lang.Exception
doStop
protected void doStop(ServiceStopper stopper)
throws java.lang.Exception
- Specified by:
doStop
in class ServiceSupport
- Throws:
java.lang.Exception
createLocalTransport
protected Transport createLocalTransport()
throws java.lang.Exception
- Throws:
java.lang.Exception
isDispatchAsync
public boolean isDispatchAsync()
setDispatchAsync
public void setDispatchAsync(boolean dispatchAsync)
getPrefetchSize
public int getPrefetchSize()
setPrefetchSize
public void setPrefetchSize(int prefetchSize)
getConnectionFilter
public ConnectionFilter getConnectionFilter()
setConnectionFilter
public void setConnectionFilter(ConnectionFilter connectionFilter)
getPassword
public java.lang.String getPassword()
setPassword
public void setPassword(java.lang.String password)
getUserName
public java.lang.String getUserName()
setUserName
public void setUserName(java.lang.String userName)
isBridgeTempDestinations
public boolean isBridgeTempDestinations()
setBridgeTempDestinations
public void setBridgeTempDestinations(boolean bridgeTempDestinations)
Copyright © 2010 Apache Software Foundation. All Rights Reserved.