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() |
void |
transportInterupted()
The transport has suffered an interuption from which it hopes to recover
|
void |
transportResumed()
The transport has resumed after an interuption
|
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onCommand, oneway, onException, reconnect, request, request, setTransportListener, toString, 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)
public void setParameters(Map<String,String> parameters)
public void transportResumed()
TransportListener
transportResumed
in interface TransportListener
transportResumed
in class TransportFilter
public void transportInterupted()
TransportListener
transportInterupted
in interface TransportListener
transportInterupted
in class TransportFilter
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.