|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.fusesource.hawtdispatch.transport.TransportFilter
public class TransportFilter
Constructor Summary | |
---|---|
TransportFilter(Transport next)
|
Method Summary | |
---|---|
void |
drainInbound()
|
void |
flush()
Forces a flush of any output buffers. |
boolean |
full()
|
Executor |
getBlockingExecutor()
|
DispatchQueue |
getDispatchQueue()
Returns the dispatch queue used by the transport |
SocketAddress |
getLocalAddress()
|
ProtocolCodec |
getProtocolCodec()
|
ReadableByteChannel |
getReadChannel()
|
SocketAddress |
getRemoteAddress()
|
TransportListener |
getTransportListener()
Returns the current transport listener |
WritableByteChannel |
getWriteChannel()
|
boolean |
isClosed()
|
boolean |
isConnected()
|
boolean |
offer(Object command)
A one way asynchronous send of a command. |
void |
resumeRead()
resume delivery of commands. |
void |
setBlockingExecutor(Executor blockingExecutor)
|
void |
setDispatchQueue(DispatchQueue queue)
Sets the dispatch queue used by the transport |
void |
setProtocolCodec(ProtocolCodec protocolCodec)
Sets the protocol codec for the transport |
void |
setTransportListener(TransportListener transportListener)
Registers an inbound command listener |
void |
start(Runnable onComplete)
Starts the service. |
void |
start(Task onComplete)
Starts the service. |
void |
stop(Runnable onComplete)
Stops the service. |
void |
stop(Task onComplete)
Stops the service. |
void |
suspendRead()
suspend delivery of commands. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public TransportFilter(Transport next)
Method Detail |
---|
public void flush()
Transport
flush
in interface Transport
public boolean full()
full
in interface Transport
public Executor getBlockingExecutor()
getBlockingExecutor
in interface Transport
public DispatchQueue getDispatchQueue()
Transport
getDispatchQueue
in interface Transport
public SocketAddress getLocalAddress()
getLocalAddress
in interface Transport
public ProtocolCodec getProtocolCodec()
getProtocolCodec
in interface Transport
public ReadableByteChannel getReadChannel()
getReadChannel
in interface Transport
public SocketAddress getRemoteAddress()
getRemoteAddress
in interface Transport
public TransportListener getTransportListener()
Transport
getTransportListener
in interface Transport
public WritableByteChannel getWriteChannel()
getWriteChannel
in interface Transport
public boolean isClosed()
isClosed
in interface Transport
public boolean isConnected()
isConnected
in interface Transport
public boolean offer(Object command)
Transport
offer
in interface Transport
public void resumeRead()
Transport
resumeRead
in interface Transport
public void setBlockingExecutor(Executor blockingExecutor)
setBlockingExecutor
in interface Transport
public void setDispatchQueue(DispatchQueue queue)
Transport
setDispatchQueue
in interface Transport
public void setProtocolCodec(ProtocolCodec protocolCodec) throws Exception
Transport
setProtocolCodec
in interface Transport
Exception
public void setTransportListener(TransportListener transportListener)
Transport
setTransportListener
in interface Transport
public void start(Runnable onComplete)
Transport
start
in interface Transport
onComplete
- my be set to null if not interested in a callback.public void start(Task onComplete)
Transport
start
in interface Transport
onComplete
- my be set to null if not interested in a callback.public void stop(Runnable onComplete)
Transport
stop
in interface Transport
onComplete
- my be set to null if not interested in a callback.public void stop(Task onComplete)
Transport
stop
in interface Transport
onComplete
- my be set to null if not interested in a callback.public void suspendRead()
Transport
suspendRead
in interface Transport
public void drainInbound()
drainInbound
in interface Transport
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |