public class ResponseCorrelator extends TransportFilter
next, transportListener
Constructor and Description |
---|
ResponseCorrelator(Transport next) |
ResponseCorrelator(Transport next,
IntSequenceGenerator sequenceGenerator) |
Modifier and Type | Method and Description |
---|---|
FutureResponse |
asyncRequest(Object o,
ResponseCallback responseCallback)
An asynchronous request response where the Receipt will be returned in
the future.
|
IntSequenceGenerator |
getSequenceGenerator() |
void |
onCommand(Object o)
called to process a command
|
void |
oneway(Object o)
A one way asynchronous send
|
void |
onException(IOException error)
If an async exception occurs, then assume no responses will arrive for
any of current requests.
|
Object |
request(Object command)
A synchronous request response
|
Object |
request(Object command,
int timeout)
A synchronous request response
|
void |
stop() |
String |
toString() |
getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, setTransportListener, start, transportInterupted, transportResumed, updateURIs
public ResponseCorrelator(Transport next)
public ResponseCorrelator(Transport next, IntSequenceGenerator sequenceGenerator)
public void oneway(Object o) throws IOException
Transport
oneway
in interface Transport
oneway
in class TransportFilter
IOException
public FutureResponse asyncRequest(Object o, ResponseCallback responseCallback) throws IOException
Transport
asyncRequest
in interface Transport
asyncRequest
in class TransportFilter
responseCallback
- TODOIOException
public Object request(Object command) throws IOException
Transport
request
in interface Transport
request
in class TransportFilter
IOException
public Object request(Object command, int timeout) throws IOException
Transport
request
in interface Transport
request
in class TransportFilter
IOException
public void onCommand(Object o)
TransportListener
onCommand
in interface TransportListener
onCommand
in class TransportFilter
public void onException(IOException error)
onException
in interface TransportListener
onException
in class TransportFilter
public void stop() throws Exception
stop
in interface Service
stop
in class TransportFilter
Exception
Service.stop()
public IntSequenceGenerator getSequenceGenerator()
public String toString()
toString
in class TransportFilter
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.