org.apache.activemq.network
Class NetworkConnector

java.lang.Object
  extended by org.apache.activemq.util.ServiceSupport
      extended by org.apache.activemq.network.NetworkConnector
All Implemented Interfaces:
Service
Direct Known Subclasses:
DiscoveryNetworkConnector, MulticastNetworkConnector

public abstract class NetworkConnector
extends ServiceSupport

Version:
$Revision$

Field Summary
protected  boolean conduitSubscriptions
           
protected  ConnectionFilter connectionFilter
           
protected  boolean dynamicOnly
           
protected  boolean failover
           
protected  java.net.URI localURI
           
protected static org.apache.commons.logging.Log log
           
 
Constructor Summary
NetworkConnector()
           
NetworkConnector(java.net.URI localURI)
           
 
Method Summary
 void addDynamicallyIncludedDestination(ActiveMQDestination destiantion)
           
 void addExcludedDestination(ActiveMQDestination destiantion)
           
 void addStaticallyIncludedDestination(ActiveMQDestination destiantion)
           
protected  Bridge configureBridge(DemandForwardingBridgeSupport result)
           
protected  Transport createLocalTransport()
           
protected abstract  java.lang.String createName()
           
protected  void doStart()
           
protected  void doStop(ServiceStopper stopper)
           
 java.lang.String getBrokerName()
           
 ConnectionFilter getConnectionFilter()
           
 java.util.Set getDurableDestinations()
           
 java.util.List getDynamicallyIncludedDestinations()
           
 java.util.List getExcludedDestinations()
           
 java.net.URI getLocalUri()
           
 java.lang.String getName()
           
 int getNetworkTTL()
           
 java.lang.String getPassword()
           
 int getPrefetchSize()
           
 java.util.List getStaticallyIncludedDestinations()
           
 java.lang.String getUserName()
           
 boolean isBridgeTempDestinations()
           
 boolean isConduitSubscriptions()
           
 boolean isDecreaseNetworkConsumerPriority()
           
 boolean isDispatchAsync()
           
 boolean isDynamicOnly()
           
 void setBridgeTempDestinations(boolean bridgeTempDestinations)
           
 void setBrokerName(java.lang.String brokerName)
           
 void setConduitSubscriptions(boolean conduitSubscriptions)
           
 void setConnectionFilter(ConnectionFilter connectionFilter)
           
 void setDecreaseNetworkConsumerPriority(boolean decreaseNetworkConsumerPriority)
           
 void setDispatchAsync(boolean dispatchAsync)
           
 void setDurableDestinations(java.util.Set durableDestinations)
           
 void setDynamicallyIncludedDestinations(java.util.List dynamicallyIncludedDestinations)
           
 void setDynamicOnly(boolean dynamicOnly)
           
 void setExcludedDestinations(java.util.List exludedDestinations)
           
 void setLocalUri(java.net.URI localURI)
           
 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 staticallyIncludedDestinations)
           
 void setUserName(java.lang.String userName)
           
 
Methods inherited from class org.apache.activemq.util.ServiceSupport
dispose, isStarted, isStopped, isStopping, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

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
Constructor Detail

NetworkConnector

public NetworkConnector()

NetworkConnector

public NetworkConnector(java.net.URI localURI)
Method Detail

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 © 2011 Apache Software Foundation. All Rights Reserved.