org.activemq.transport
Class DiscoveryNetworkConnector
java.lang.Object
org.activemq.transport.NetworkConnector
org.activemq.transport.DiscoveryNetworkConnector
- All Implemented Interfaces:
- DiscoveryListener, Service
- public class DiscoveryNetworkConnector
- extends NetworkConnector
- implements DiscoveryListener
A NetworkConnector
which uses discovery to find remote brokers to connect to
- Version:
- $Revision: 1.1.1.1 $
Methods inherited from class org.activemq.transport.NetworkConnector |
addNetworkChannel, addNetworkChannel, configure, createNetworkChannel, getBrokerContainer, getLocalDetails, getLocalDurableTopicPrefetch, getLocalPrefetchPolicy, getLocalQueueBrowserPrefetch, getLocalQueuePrefetch, getLocalTopicPrefetch, getNetworkChannels, getRemoteDurableTopicPrefetch, getRemotePassword, getRemotePrefetchPolicy, getRemoteQueueBrowserPrefetch, getRemoteQueuePrefetch, getRemoteTopicPrefetch, getRemoteUserName, getThreadPool, removeNetworkChannel, setLocalDetails, setLocalDurableTopicPrefetch, setLocalPrefetchPolicy, setLocalQueueBrowserPrefetch, setLocalQueuePrefetch, setLocalTopicPrefetch, setNetworkChannels, setRemoteDurableTopicPrefetch, setRemotePassword, setRemotePrefetchPolicy, setRemoteQueueBrowserPrefetch, setRemoteQueuePrefetch, setRemoteTopicPrefetch, setRemoteUserName, setTransportChannelListener, stop |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DiscoveryNetworkConnector
public DiscoveryNetworkConnector(BrokerContainer brokerContainer)
start
public void start()
throws JMSException
- Description copied from interface:
Service
- Called to start the service
- Specified by:
start
in interface Service
- Overrides:
start
in class NetworkConnector
- Throws:
JMSException
addService
public void addService(DiscoveryEvent event)
- Description copied from interface:
DiscoveryListener
- A service has started
- Specified by:
addService
in interface DiscoveryListener
- Parameters:
event
-
removeService
public void removeService(DiscoveryEvent event)
- Description copied from interface:
DiscoveryListener
- A service has stopped
- Specified by:
removeService
in interface DiscoveryListener
- Parameters:
event
-
addChannel
protected void addChannel(String url,
Map details)
removeChannel
protected void removeChannel(String url,
Map details)
getLocalBrokerName
protected String getLocalBrokerName()
Copyright © 2004-2007 Protique, Ltd.. All Rights Reserved.