public class DiscoveryTransport extends TransportFilter implements DiscoveryListener
ReliableTransportChannel
which uses a DiscoveryAgent
to
discover remote broker instances and dynamically connect to them.transportListener
DISCOVERED_OPTION_PREFIX
Constructor and Description |
---|
DiscoveryTransport(CompositeTransport next) |
Modifier and Type | Method and Description |
---|---|
DiscoveryAgent |
getDiscoveryAgent() |
void |
onServiceAdd(DiscoveryEvent event) |
void |
onServiceRemove(DiscoveryEvent event) |
void |
setDiscoveryAgent(DiscoveryAgent discoveryAgent) |
void |
setParameters(Map<String,String> parameters) |
void |
start() |
void |
stop() |
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onCommand, oneway, onException, reconnect, request, request, setTransportListener, toString, transportInterupted, transportResumed, updateURIs
public DiscoveryTransport(CompositeTransport next)
public void start() throws Exception
start
in interface Service
start
in class TransportFilter
Exception
Service.start()
public void stop() throws Exception
stop
in interface Service
stop
in class TransportFilter
Exception
Service.stop()
public void onServiceAdd(DiscoveryEvent event)
onServiceAdd
in interface DiscoveryListener
public void onServiceRemove(DiscoveryEvent event)
onServiceRemove
in interface DiscoveryListener
public DiscoveryAgent getDiscoveryAgent()
public void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.