org.apache.activemq.transport.discovery
Class DiscoveryTransport

java.lang.Object
  extended by org.apache.activemq.transport.TransportFilter
      extended by org.apache.activemq.transport.discovery.DiscoveryTransport
All Implemented Interfaces:
Service, DiscoveryListener, Transport, TransportListener

public class DiscoveryTransport
extends TransportFilter
implements DiscoveryListener

A ReliableTransportChannel which uses a DiscoveryAgent to discover remote broker instances and dynamically connect to them.

Version:
$Revision$

Field Summary
 
Fields inherited from class org.apache.activemq.transport.TransportFilter
transportListener
 
Constructor Summary
DiscoveryTransport(CompositeTransport next)
           
 
Method Summary
 DiscoveryAgent getDiscoveryAgent()
           
 void onServiceAdd(DiscoveryEvent event)
           
 void onServiceRemove(DiscoveryEvent event)
           
 void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
           
 void start()
           
 void stop()
           
 
Methods inherited from class org.apache.activemq.transport.TransportFilter
asyncRequest, getNext, getRemoteAddress, getTransportListener, narrow, onCommand, oneway, onException, request, request, setTransportListener, toString, transportInterupted, transportResumed
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

DiscoveryTransport

public DiscoveryTransport(CompositeTransport next)
Method Detail

start

public void start()
           throws java.lang.Exception
Specified by:
start in interface Service
Overrides:
start in class TransportFilter
Throws:
java.lang.Exception
See Also:
Service.start()

stop

public void stop()
          throws java.lang.Exception
Specified by:
stop in interface Service
Overrides:
stop in class TransportFilter
Throws:
java.lang.Exception
See Also:
Service.stop()

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)


Copyright © 2011 Apache Software Foundation. All Rights Reserved.