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
Methods inherited from class org.apache.activemq.network.NetworkConnector |
activeBridges, addDynamicallyIncludedDestination, addExcludedDestination, addStaticallyIncludedDestination, configureBridge, createLocalTransport, createNetworkBridgeObjectName, getBrokerService, getConnectionFilter, getDurableDestinations, getDynamicallyIncludedDestinations, getExcludedDestinations, getLocalUri, getObjectName, getStaticallyIncludedDestinations, isStarted, isStopped, isStopping, registerNetworkBridgeMBean, removeDemandSubscription, setBrokerService, setConnectionFilter, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setLocalUri, setObjectName, setStaticallyIncludedDestinations, start, stop, unregisterNetworkBridgeMBean |
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, setAlwaysSyncSend, setBridgeTempDestinations, setBrokerName, setBrokerURL, setConduitSubscriptions, setConsumerPriorityBase, setDecreaseNetworkConsumerPriority, setDestinationFilter, setDispatchAsync, setDuplex, setDynamicOnly, setName, setNetworkTTL, setPassword, setPrefetchSize, setStaticBridge, setSuppressDuplicateQueueSubscriptions, setSuppressDuplicateTopicSubscriptions, setUserName |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, 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)
handleStart
protected void handleStart()
throws java.lang.Exception
- Overrides:
handleStart
in class NetworkConnector
- Throws:
java.lang.Exception
handleStop
protected void handleStop(ServiceStopper stopper)
throws java.lang.Exception
- Overrides:
handleStop
in class NetworkConnector
- Throws:
java.lang.Exception
createBridge
protected NetworkBridge createBridge(Transport localTransport,
Transport remoteTransport,
DiscoveryEvent event)
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
Copyright © 2005-2016. All Rights Reserved.