org.apache.activemq.transport.discovery
Class DiscoveryTransport
java.lang.Object
org.apache.activemq.transport.TransportFilter
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.
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 |
DiscoveryTransport
public DiscoveryTransport(CompositeTransport next)
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-2016. All Rights Reserved.