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.


Field Summary
 
Fields inherited from class org.apache.activemq.transport.TransportFilter
transportListener
 
Fields inherited from interface org.apache.activemq.transport.discovery.DiscoveryListener
DISCOVERED_OPTION_PREFIX
 
Constructor Summary
DiscoveryTransport(CompositeTransport next)
           
 
Method Summary
 DiscoveryAgent getDiscoveryAgent()
           
 void onServiceAdd(DiscoveryEvent event)
           
 void onServiceRemove(DiscoveryEvent event)
           
 void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
           
 void setParameters(java.util.Map<java.lang.String,java.lang.String> parameters)
           
 void start()
           
 void stop()
           
 
Methods inherited from class org.apache.activemq.transport.TransportFilter
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onCommand, oneway, onException, reconnect, request, request, setTransportListener, toString, transportInterupted, transportResumed, updateURIs
 
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)

setParameters

public void setParameters(java.util.Map<java.lang.String,java.lang.String> parameters)


Copyright © 2005-2011 FuseSource, Corp.. All Rights Reserved.