|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface Transport
Represents an abstract connection. It can be a client side or server side connection.
Method Summary | ||
---|---|---|
boolean |
full()
|
|
org.fusesource.hawtdispatch.DispatchQueue |
getDispatchQueue()
Returns the dispatch queue used by the transport |
|
ProtocolCodec |
getProtocolCodec()
|
|
java.lang.String |
getRemoteAddress()
|
|
TransportListener |
getTransportListener()
Returns the current transport listener |
|
java.lang.String |
getTypeId()
|
|
boolean |
isConnected()
|
|
boolean |
isDisposed()
|
|
boolean |
isFaultTolerant()
Indicates if the transport can handle faults |
|
|
narrow(java.lang.Class<T> target)
|
|
boolean |
offer(java.lang.Object command)
A one way asynchronous send of a command. |
|
void |
reconnect(java.net.URI uri)
reconnect to another location |
|
void |
resumeRead()
resume delivery of commands. |
|
void |
setDispatchQueue(org.fusesource.hawtdispatch.DispatchQueue queue)
Sets the dispatch queue used by the transport |
|
void |
setProtocolCodec(ProtocolCodec protocolCodec)
Sets the protocol codec for the transport |
|
void |
setTransportListener(TransportListener commandListener)
Registers an inbound command listener |
|
void |
suspendRead()
suspend delivery of commands. |
Methods inherited from interface org.apache.activemq.apollo.util.Service |
---|
start, start, stop, stop |
Method Detail |
---|
boolean full()
boolean offer(java.lang.Object command)
command
-
TransportListener getTransportListener()
void setTransportListener(TransportListener commandListener)
commandListener
- org.fusesource.hawtdispatch.DispatchQueue getDispatchQueue()
void setDispatchQueue(org.fusesource.hawtdispatch.DispatchQueue queue)
queue
- void suspendRead()
void resumeRead()
<T> T narrow(java.lang.Class<T> target)
target
-
java.lang.String getRemoteAddress()
boolean isFaultTolerant()
boolean isDisposed()
boolean isConnected()
ProtocolCodec getProtocolCodec()
void setProtocolCodec(ProtocolCodec protocolCodec)
protocolCodec
- void reconnect(java.net.URI uri)
uri
-
java.io.IOException
- on failure of if not supportedjava.lang.String getTypeId()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |