|
||||||||||
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(Object command,
ResponseCallback responseCallback)
An asynchronous request response where the Receipt will be returned in the future. |
String |
getRemoteAddress()
|
TransportListener |
getTransportListener()
Returns the current transport listener |
Object |
narrow(Class target)
|
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 |
setTransportListener(TransportListener commandListener)
Registers an inbound command listener |
Methods inherited from interface org.apache.activemq.Service |
---|
start, stop |
Method Detail |
---|
void oneway(Object command) throws IOException
command
-
IOException
FutureResponse asyncRequest(Object command, ResponseCallback responseCallback) throws IOException
command
- responseCallback
- TODO
IOException
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
- Object narrow(Class target)
target
-
String getRemoteAddress()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |