public class MutexTransport extends TransportFilter
next, transportListener
Constructor and Description |
---|
MutexTransport(Transport next) |
MutexTransport(Transport next,
boolean syncOnCommand) |
Modifier and Type | Method and Description |
---|---|
FutureResponse |
asyncRequest(Object command,
ResponseCallback responseCallback)
An asynchronous request response where the Receipt will be returned in
the future.
|
boolean |
isSyncOnCommand() |
void |
onCommand(Object command)
called to process a command
|
void |
oneway(Object command)
A one way asynchronous send
|
Object |
request(Object command)
A synchronous request response
|
Object |
request(Object command,
int timeout)
A synchronous request response
|
void |
setSyncOnCommand(boolean syncOnCommand) |
String |
toString() |
getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onException, reconnect, setTransportListener, start, stop, transportInterupted, transportResumed, updateURIs
public MutexTransport(Transport next)
public MutexTransport(Transport next, boolean syncOnCommand)
public void onCommand(Object command)
TransportListener
onCommand
in interface TransportListener
onCommand
in class TransportFilter
public FutureResponse asyncRequest(Object command, ResponseCallback responseCallback) throws IOException
Transport
asyncRequest
in interface Transport
asyncRequest
in class TransportFilter
responseCallback
- TODOIOException
public void oneway(Object command) throws IOException
Transport
oneway
in interface Transport
oneway
in class TransportFilter
IOException
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 String toString()
toString
in class TransportFilter
public boolean isSyncOnCommand()
public void setSyncOnCommand(boolean syncOnCommand)
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.