org.activemq.transport
Class DiscoveryNetworkConnector

java.lang.Object
  extended by org.activemq.transport.NetworkConnector
      extended by org.activemq.transport.DiscoveryNetworkConnector
All Implemented Interfaces:
Service, DiscoveryListener

public class DiscoveryNetworkConnector
extends NetworkConnector
implements DiscoveryListener

A NetworkConnectorwhich uses discovery to find remote brokers to connect to

Version:
$Revision: 1.1.1.1 $

Field Summary
 
Fields inherited from class org.activemq.transport.NetworkConnector
threadPool
 
Constructor Summary
DiscoveryNetworkConnector(BrokerContainer brokerContainer)
           
 
Method Summary
protected  void addChannel(String url, Map details)
           
 void addService(DiscoveryEvent event)
          A service has started
protected  String getLocalBrokerName()
           
protected  void removeChannel(String url, Map details)
           
 void removeService(DiscoveryEvent event)
          A service has stopped
 void start()
          Called to start the service
 
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
 

Constructor Detail

DiscoveryNetworkConnector

public DiscoveryNetworkConnector(BrokerContainer brokerContainer)
Method Detail

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

removeService

public void removeService(DiscoveryEvent event)
Description copied from interface: DiscoveryListener
A service has stopped

Specified by:
removeService in interface DiscoveryListener

addChannel

protected void addChannel(String url,
                          Map details)

removeChannel

protected void removeChannel(String url,
                             Map details)

getLocalBrokerName

protected String getLocalBrokerName()


Copyright © 2004-2010 Protique, Ltd.. All Rights Reserved.