org.apache.activemq.network
Class DiscoveryNetworkConnector
java.lang.Object
org.apache.activemq.util.ServiceSupport
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: 426366 $
Methods inherited from class org.apache.activemq.network.NetworkConnector |
addDynamicallyIncludedDestination, addExcludedDestination, addStaticallyIncludedDestination, configureBridge, createLocalTransport, getBrokerName, getConnectionFilter, getDurableDestinations, getDynamicallyIncludedDestinations, getExcludedDestinations, getLocalUri, getName, getNetworkTTL, getPassword, getPrefetchSize, getStaticallyIncludedDestinations, getUserName, isBridgeTempDestinations, isConduitSubscriptions, isDecreaseNetworkConsumerPriority, isDispatchAsync, isDynamicOnly, setBridgeTempDestinations, setBrokerName, setConduitSubscriptions, setConnectionFilter, setDecreaseNetworkConsumerPriority, setDispatchAsync, setDurableDestinations, setDynamicallyIncludedDestinations, setDynamicOnly, setExcludedDestinations, setLocalUri, setName, setNetworkTTL, setPassword, setPrefetchSize, setStaticallyIncludedDestinations, setUserName |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DiscoveryNetworkConnector
public DiscoveryNetworkConnector()
DiscoveryNetworkConnector
public DiscoveryNetworkConnector(java.net.URI discoveryURI)
throws java.io.IOException
- Throws:
java.io.IOException
setUri
public void setUri(java.net.URI discoveryURI)
throws java.io.IOException
- Throws:
java.io.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)
isFailover
public boolean isFailover()
setFailover
public void setFailover(boolean reliable)
doStart
protected void doStart()
throws java.lang.Exception
- Overrides:
doStart
in class NetworkConnector
- Throws:
java.lang.Exception
doStop
protected void doStop(ServiceStopper stopper)
throws java.lang.Exception
- Overrides:
doStop
in class NetworkConnector
- Throws:
java.lang.Exception
createBridge
protected Bridge createBridge(Transport localTransport,
Transport remoteTransport,
DiscoveryEvent event)
createName
protected java.lang.String createName()
- Specified by:
createName
in class NetworkConnector
Copyright © 2011 Apache Software Foundation. All Rights Reserved.