org.apache.activemq.network
Class DiscoveryNetworkConnector
java.lang.Object
org.apache.activemq.network.NetworkBridgeConfiguration
org.apache.activemq.network.NetworkConnector
org.apache.activemq.network.DiscoveryNetworkConnector
- All Implemented Interfaces:
- Service, DiscoveryListener
public class DiscoveryNetworkConnector
- extends NetworkConnector
- implements DiscoveryListener
A network connector which uses a discovery agent to detect the remote brokers
available and setup a connection to each available remote broker
- Version:
- $Revision: 824823 $
Methods inherited from class org.apache.activemq.network.NetworkConnector |
activeBridges, addDynamicallyIncludedDestination, addExcludedDestination, addStaticallyIncludedDestination, configureBridge, createLocalTransport, createNetworkBridgeObjectName, getBrokerService, getConnectionFilter, getDurableDestinations, getDynamicallyIncludedDestinations, getExcludedDestinations, getLocalUri, getObjectName, getStaticallyIncludedDestinations, registerNetworkBridgeMBean, removeDemandSubscription, setBrokerService, setConnectionFilter, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setLocalUri, setObjectName, setStaticallyIncludedDestinations, start, stop, unregisterNetworkBridgeMBean |
Methods inherited from class org.apache.activemq.network.NetworkBridgeConfiguration |
getBrokerName, getDestinationFilter, getNetworkTTL, getPassword, getPrefetchSize, getUserName, isBridgeTempDestinations, isConduitSubscriptions, isDecreaseNetworkConsumerPriority, isDispatchAsync, isDuplex, isDynamicOnly, isSuppressDuplicateQueueSubscriptions, setBridgeTempDestinations, setBrokerName, setConduitSubscriptions, setDecreaseNetworkConsumerPriority, setDestinationFilter, setDispatchAsync, setDuplex, setDynamicOnly, setName, setNetworkTTL, setPassword, setPrefetchSize, setSuppressDuplicateQueueSubscriptions, setUserName |
DiscoveryNetworkConnector
public DiscoveryNetworkConnector()
DiscoveryNetworkConnector
public DiscoveryNetworkConnector(URI discoveryURI)
throws IOException
- Throws:
IOException
setUri
public void setUri(URI discoveryURI)
throws IOException
- Throws:
IOException
onServiceAdd
public void onServiceAdd(DiscoveryEvent event)
- Specified by:
onServiceAdd
in interface DiscoveryListener
onServiceRemove
public void onServiceRemove(DiscoveryEvent event)
- Specified by:
onServiceRemove
in interface DiscoveryListener
getDiscoveryAgent
public DiscoveryAgent getDiscoveryAgent()
setDiscoveryAgent
public void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
handleStart
protected void handleStart()
throws Exception
- Overrides:
handleStart
in class NetworkConnector
- Throws:
Exception
handleStop
protected void handleStop(ServiceStopper stopper)
throws Exception
- Overrides:
handleStop
in class NetworkConnector
- Throws:
Exception
createBridge
protected NetworkBridge createBridge(Transport localTransport,
Transport remoteTransport,
DiscoveryEvent event)
getName
public String getName()
- Overrides:
getName
in class NetworkBridgeConfiguration
- Returns:
- the name
toString
public String toString()
- Overrides:
toString
in class Object
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.