public class DiscoveryNetworkConnector extends NetworkConnector implements DiscoveryListener
bridges, connectionFilter, localURI, serviceSupport
dynamicallyIncludedDestinations, excludedDestinations, staticallyIncludedDestinations
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() |
URI |
getUri() |
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, getDurableTopicDestinations, getLocalUri, getObjectName, isStarted, isStopped, isStopping, registerNetworkBridgeMBean, removeDemandSubscription, setBrokerService, setConnectionFilter, setDurableDestinations, setLocalUri, setObjectName, start, stop, unregisterNetworkBridgeMBean
getAdvisoryAckPercentage, getAdvisoryPrefetchSize, getBrokerName, getBrokerURL, getConsumerPriorityBase, getConsumerTTL, getDestinationFilter, getDynamicallyIncludedDestinations, getExcludedDestinations, getGcSweepTime, getMessageTTL, getName, getNetworkTTL, getPassword, getPrefetchSize, getStaticallyIncludedDestinations, getUserName, isAdvisoryForFailedForward, isAlwaysSyncSend, isBridgeTempDestinations, isCheckDuplicateMessagesOnDuplex, isConduitSubscriptions, isDecreaseNetworkConsumerPriority, isDispatchAsync, isDuplex, isDynamicOnly, isGcDestinationViews, isStaticBridge, isSuppressDuplicateQueueSubscriptions, isSuppressDuplicateTopicSubscriptions, isSyncDurableSubs, isUseBrokerNamesAsIdSeed, isUseCompression, isUseVirtualDestSubs, isUseVirtualDestSus, setAdvisoryAckPercentage, setAdvisoryForFailedForward, setAdvisoryPrefetchSize, setAlwaysSyncSend, setBridgeTempDestinations, setBrokerName, setBrokerURL, setCheckDuplicateMessagesOnDuplex, setConduitSubscriptions, setConsumerPriorityBase, setConsumerTTL, setDecreaseNetworkConsumerPriority, setDestinationFilter, setDispatchAsync, setDuplex, setDynamicallyIncludedDestinations, setDynamicOnly, setExcludedDestinations, setGcDestinationViews, setGcSweepTime, setMessageTTL, setName, setNetworkTTL, setPassword, setPrefetchSize, setStaticallyIncludedDestinations, setStaticBridge, setSuppressDuplicateQueueSubscriptions, setSuppressDuplicateTopicSubscriptions, setSyncDurableSubs, setUseBrokerNameAsIdSees, setUseCompression, setUserName, setUseVirtualDestSubs
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–2020 The Apache Software Foundation. All rights reserved.