org.apache.activemq.network
Class NetworkConnector

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

public abstract class NetworkConnector
extends NetworkBridgeConfiguration
implements Service

Connector class for bridging broker networks.


Field Summary
protected  ConcurrentHashMap<URI,NetworkBridge> bridges
           
protected  ConnectionFilter connectionFilter
           
protected  URI localURI
           
protected  ServiceSupport serviceSupport
           
 
Constructor Summary
NetworkConnector()
           
NetworkConnector(URI localURI)
           
 
Method Summary
 Collection<NetworkBridge> activeBridges()
           
 void addDynamicallyIncludedDestination(ActiveMQDestination destiantion)
           
 void addExcludedDestination(ActiveMQDestination destiantion)
           
 void addStaticallyIncludedDestination(ActiveMQDestination destiantion)
           
protected  NetworkBridge configureBridge(DemandForwardingBridgeSupport result)
           
protected  Transport createLocalTransport()
           
protected  ObjectName createNetworkBridgeObjectName(NetworkBridge bridge)
           
 BrokerService getBrokerService()
           
 ConnectionFilter getConnectionFilter()
           
 Set<ActiveMQDestination> getDurableDestinations()
           
 List<ActiveMQDestination> getDynamicallyIncludedDestinations()
           
 List<ActiveMQDestination> getExcludedDestinations()
           
 URI getLocalUri()
           
 ObjectName getObjectName()
           
 List<ActiveMQDestination> getStaticallyIncludedDestinations()
           
protected  void handleStart()
           
protected  void handleStop(ServiceStopper stopper)
           
 boolean isStarted()
           
 boolean isStopped()
           
 boolean isStopping()
           
protected  void registerNetworkBridgeMBean(NetworkBridge bridge)
           
 boolean removeDemandSubscription(ConsumerId consumerId)
           
 void setBrokerService(BrokerService brokerService)
           
 void setConnectionFilter(ConnectionFilter connectionFilter)
           
 void setDurableDestinations(Set<ActiveMQDestination> durableDestinations)
           
 void setDynamicallyIncludedDestinations(List<ActiveMQDestination> dynamicallyIncludedDestinations)
           
 void setExcludedDestinations(List<ActiveMQDestination> excludedDestinations)
           
 void setLocalUri(URI localURI)
           
 void setObjectName(ObjectName objectName)
           
 void setStaticallyIncludedDestinations(List<ActiveMQDestination> staticallyIncludedDestinations)
           
 void start()
           
 void stop()
           
protected  void unregisterNetworkBridgeMBean(NetworkBridge bridge)
           
 
Methods inherited from class org.apache.activemq.network.NetworkBridgeConfiguration
getBrokerName, getBrokerURL, getConsumerPriorityBase, getDestinationFilter, getName, getNetworkTTL, getPassword, getPrefetchSize, getUserName, isAlwaysSyncSend, isBridgeTempDestinations, isConduitSubscriptions, isDecreaseNetworkConsumerPriority, isDispatchAsync, isDuplex, isDynamicOnly, isStaticBridge, isSuppressDuplicateQueueSubscriptions, isSuppressDuplicateTopicSubscriptions, isUseCompression, setAlwaysSyncSend, setBridgeTempDestinations, setBrokerName, setBrokerURL, setConduitSubscriptions, setConsumerPriorityBase, setDecreaseNetworkConsumerPriority, setDestinationFilter, setDispatchAsync, setDuplex, setDynamicOnly, setName, setNetworkTTL, setPassword, setPrefetchSize, setStaticBridge, setSuppressDuplicateQueueSubscriptions, setSuppressDuplicateTopicSubscriptions, setUseCompression, setUserName
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

localURI

protected URI localURI

connectionFilter

protected ConnectionFilter connectionFilter

bridges

protected ConcurrentHashMap<URI,NetworkBridge> bridges

serviceSupport

protected ServiceSupport serviceSupport
Constructor Detail

NetworkConnector

public NetworkConnector()

NetworkConnector

public NetworkConnector(URI localURI)
Method Detail

getLocalUri

public URI getLocalUri()
                throws URISyntaxException
Throws:
URISyntaxException

setLocalUri

public void setLocalUri(URI localURI)

getDurableDestinations

public Set<ActiveMQDestination> getDurableDestinations()
Returns:
Returns the durableDestinations.

setDurableDestinations

public void setDurableDestinations(Set<ActiveMQDestination> durableDestinations)
Parameters:
durableDestinations - The durableDestinations to set.

getExcludedDestinations

public List<ActiveMQDestination> getExcludedDestinations()
Overrides:
getExcludedDestinations in class NetworkBridgeConfiguration
Returns:
Returns the excludedDestinations.

setExcludedDestinations

public void setExcludedDestinations(List<ActiveMQDestination> excludedDestinations)
Overrides:
setExcludedDestinations in class NetworkBridgeConfiguration
Parameters:
excludedDestinations - The excludedDestinations to set.

addExcludedDestination

public void addExcludedDestination(ActiveMQDestination destiantion)

getStaticallyIncludedDestinations

public List<ActiveMQDestination> getStaticallyIncludedDestinations()
Overrides:
getStaticallyIncludedDestinations in class NetworkBridgeConfiguration
Returns:
Returns the staticallyIncludedDestinations.

setStaticallyIncludedDestinations

public void setStaticallyIncludedDestinations(List<ActiveMQDestination> staticallyIncludedDestinations)
Overrides:
setStaticallyIncludedDestinations in class NetworkBridgeConfiguration
Parameters:
staticallyIncludedDestinations - The staticallyIncludedDestinations to set.

addStaticallyIncludedDestination

public void addStaticallyIncludedDestination(ActiveMQDestination destiantion)

getDynamicallyIncludedDestinations

public List<ActiveMQDestination> getDynamicallyIncludedDestinations()
Overrides:
getDynamicallyIncludedDestinations in class NetworkBridgeConfiguration
Returns:
Returns the dynamicallyIncludedDestinations.

setDynamicallyIncludedDestinations

public void setDynamicallyIncludedDestinations(List<ActiveMQDestination> dynamicallyIncludedDestinations)
Overrides:
setDynamicallyIncludedDestinations in class NetworkBridgeConfiguration
Parameters:
dynamicallyIncludedDestinations - The dynamicallyIncludedDestinations to set.

addDynamicallyIncludedDestination

public void addDynamicallyIncludedDestination(ActiveMQDestination destiantion)

getConnectionFilter

public ConnectionFilter getConnectionFilter()

setConnectionFilter

public void setConnectionFilter(ConnectionFilter connectionFilter)

configureBridge

protected NetworkBridge configureBridge(DemandForwardingBridgeSupport result)

createLocalTransport

protected Transport createLocalTransport()
                                  throws Exception
Throws:
Exception

start

public void start()
           throws Exception
Specified by:
start in interface Service
Throws:
Exception

stop

public void stop()
          throws Exception
Specified by:
stop in interface Service
Throws:
Exception

handleStart

protected void handleStart()
                    throws Exception
Throws:
Exception

handleStop

protected void handleStop(ServiceStopper stopper)
                   throws Exception
Throws:
Exception

isStarted

public boolean isStarted()

isStopped

public boolean isStopped()

isStopping

public boolean isStopping()

getObjectName

public ObjectName getObjectName()

setObjectName

public void setObjectName(ObjectName objectName)

getBrokerService

public BrokerService getBrokerService()

setBrokerService

public void setBrokerService(BrokerService brokerService)

registerNetworkBridgeMBean

protected void registerNetworkBridgeMBean(NetworkBridge bridge)

unregisterNetworkBridgeMBean

protected void unregisterNetworkBridgeMBean(NetworkBridge bridge)

createNetworkBridgeObjectName

protected ObjectName createNetworkBridgeObjectName(NetworkBridge bridge)
                                            throws MalformedObjectNameException
Throws:
MalformedObjectNameException

removeDemandSubscription

public boolean removeDemandSubscription(ConsumerId consumerId)

activeBridges

public Collection<NetworkBridge> activeBridges()


Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.