public class DiscoveryNetworkConnector extends NetworkConnector implements DiscoveryListener
bridges, connectionFilter, localURI, serviceSupport
DISCOVERED_OPTION_PREFIX
Constructor and Description |
---|
DiscoveryNetworkConnector() |
DiscoveryNetworkConnector(URI discoveryURI) |
Modifier and Type | Method and Description |
---|---|
protected NetworkBridge |
createBridge(Transport localTransport,
Transport remoteTransport,
DiscoveryEvent event) |
DiscoveryAgent |
getDiscoveryAgent() |
protected void |
handleStart() |
protected void |
handleStop(ServiceStopper stopper) |
void |
onServiceAdd(DiscoveryEvent event) |
void |
onServiceRemove(DiscoveryEvent event) |
void |
setDiscoveryAgent(DiscoveryAgent discoveryAgent) |
void |
setUri(URI discoveryURI) |
String |
toString() |
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
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
public DiscoveryNetworkConnector()
public DiscoveryNetworkConnector(URI discoveryURI) throws IOException
IOException
public void setUri(URI discoveryURI) throws IOException
IOException
public void onServiceAdd(DiscoveryEvent event)
onServiceAdd
in interface DiscoveryListener
public void onServiceRemove(DiscoveryEvent event)
onServiceRemove
in interface DiscoveryListener
public DiscoveryAgent getDiscoveryAgent()
public void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
protected void handleStart() throws Exception
handleStart
in class NetworkConnector
Exception
protected void handleStop(ServiceStopper stopper) throws Exception
handleStop
in class NetworkConnector
Exception
protected NetworkBridge createBridge(Transport localTransport, Transport remoteTransport, DiscoveryEvent event)
Copyright © 2005-2012 Apache Software Foundation. All Rights Reserved.