public interface Transport extends Service
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.
|
int |
getReceiveCounter()
Returns a counter which gets incremented as data is read from the transport.
|
String |
getRemoteAddress() |
TransportListener |
getTransportListener()
Returns the current transport listener
|
boolean |
isConnected() |
boolean |
isDisposed() |
boolean |
isFaultTolerant()
Indicates if the transport can handle faults
|
boolean |
isReconnectSupported() |
boolean |
isUpdateURIsSupported() |
<T> T |
narrow(Class<T> target) |
void |
oneway(Object command)
A one way asynchronous send
|
void |
reconnect(URI uri)
reconnect to another location
|
Object |
request(Object command)
A synchronous request response
|
Object |
request(Object command,
int timeout)
A synchronous request response
|
void |
setTransportListener(TransportListener commandListener)
Registers an inbound command listener
|
void |
updateURIs(boolean rebalance,
URI[] uris)
Provide a list of available alternative locations
|
void oneway(Object command) throws IOException
command
- IOException
FutureResponse asyncRequest(Object command, ResponseCallback responseCallback) throws IOException
command
- responseCallback
- TODOIOException
Object request(Object command) throws IOException
command
- IOException
Object request(Object command, int timeout) throws IOException
command
- timeout
- IOException
TransportListener getTransportListener()
void setTransportListener(TransportListener commandListener)
commandListener
- String getRemoteAddress()
boolean isFaultTolerant()
boolean isDisposed()
boolean isConnected()
boolean isReconnectSupported()
boolean isUpdateURIsSupported()
void reconnect(URI uri) throws IOException
uri
- IOException
- on failure of if not supportedvoid updateURIs(boolean rebalance, URI[] uris) throws IOException
rebalance
- uris
- IOException
int getReceiveCounter()
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.