|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface Transport
Represents the client side of a transport allowing messages to be sent synchronously, asynchronously and consumed.
Method Summary | ||
---|---|---|
FutureResponse |
asyncRequest(java.lang.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. |
|
java.lang.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()
|
|
|
narrow(java.lang.Class<T> target)
|
|
void |
oneway(java.lang.Object command)
A one way asynchronous send |
|
void |
reconnect(java.net.URI uri)
reconnect to another location |
|
java.lang.Object |
request(java.lang.Object command)
A synchronous request response |
|
java.lang.Object |
request(java.lang.Object command,
int timeout)
A synchronous request response |
|
void |
setTransportListener(TransportListener commandListener)
Registers an inbound command listener |
|
void |
updateURIs(boolean rebalance,
java.net.URI[] uris)
Provide a list of available alternative locations |
Methods inherited from interface org.apache.activemq.Service |
---|
start, stop |
Method Detail |
---|
void oneway(java.lang.Object command) throws java.io.IOException
command
-
java.io.IOException
FutureResponse asyncRequest(java.lang.Object command, ResponseCallback responseCallback) throws java.io.IOException
command
- responseCallback
- TODO
java.io.IOException
java.lang.Object request(java.lang.Object command) throws java.io.IOException
command
-
java.io.IOException
java.lang.Object request(java.lang.Object command, int timeout) throws java.io.IOException
command
- timeout
-
java.io.IOException
TransportListener getTransportListener()
void setTransportListener(TransportListener commandListener)
commandListener
- <T> T narrow(java.lang.Class<T> target)
target
-
java.lang.String getRemoteAddress()
boolean isFaultTolerant()
boolean isDisposed()
boolean isConnected()
boolean isReconnectSupported()
boolean isUpdateURIsSupported()
void reconnect(java.net.URI uri) throws java.io.IOException
uri
-
java.io.IOException
- on failure of if not supportedvoid updateURIs(boolean rebalance, java.net.URI[] uris) throws java.io.IOException
rebalance
- uris
-
java.io.IOException
int getReceiveCounter()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |