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
           
 
Fields inherited from class org.apache.activemq.network.NetworkBridgeConfiguration
dynamicallyIncludedDestinations, excludedDestinations, staticallyIncludedDestinations
 
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()
           
 URI getLocalUri()
           
 ObjectName getObjectName()
           
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 setLocalUri(URI localURI)
           
 void setObjectName(ObjectName objectName)
           
 void start()
           
 void stop()
           
protected  void unregisterNetworkBridgeMBean(NetworkBridge bridge)
           
 
Methods inherited from class org.apache.activemq.network.NetworkBridgeConfiguration
getBrokerName, getBrokerURL, getConsumerPriorityBase, getDestinationFilter, getDynamicallyIncludedDestinations, getExcludedDestinations, getName, getNetworkTTL, getPassword, getPrefetchSize, getStaticallyIncludedDestinations, getUserName, isAdvisoryForFailedForward, isAlwaysSyncSend, isBridgeTempDestinations, isConduitSubscriptions, isDecreaseNetworkConsumerPriority, isDispatchAsync, isDuplex, isDynamicOnly, isStaticBridge, isSuppressDuplicateQueueSubscriptions, isSuppressDuplicateTopicSubscriptions, isUseCompression, setAdvisoryForFailedForward, setAlwaysSyncSend, setBridgeTempDestinations, setBrokerName, setBrokerURL, setConduitSubscriptions, setConsumerPriorityBase, setDecreaseNetworkConsumerPriority, setDestinationFilter, setDispatchAsync, setDuplex, setDynamicallyIncludedDestinations, setDynamicOnly, setExcludedDestinations, setName, setNetworkTTL, setPassword, setPrefetchSize, setStaticallyIncludedDestinations, 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.

addExcludedDestination

public void addExcludedDestination(ActiveMQDestination destiantion)

addStaticallyIncludedDestination

public void addStaticallyIncludedDestination(ActiveMQDestination destiantion)

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-2013 The Apache Software Foundation. All Rights Reserved.