|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.fusesource.hawtdispatch.transport.PipeTransport
public class PipeTransport
Constructor Summary | |
---|---|
PipeTransport(PipeTransportServer server)
|
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()
|
long |
getReadCounter()
|
SocketAddress |
getRemoteAddress()
|
TransportListener |
getTransportListener()
Returns the current transport listener |
WritableByteChannel |
getWriteChannel()
|
long |
getWriteCounter()
|
boolean |
isClosed()
|
boolean |
isConnected()
|
boolean |
isMarshal()
|
boolean |
isTrace()
|
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 |
setMarshal(boolean marshall)
|
void |
setName(String name)
|
void |
setProtocolCodec(ProtocolCodec protocolCodec)
Sets the protocol codec for the transport |
void |
setRemoteAddress(String remoteAddress)
|
void |
setTrace(boolean trace)
|
void |
setTransportListener(TransportListener transportListener)
Registers an inbound command listener |
void |
start(Runnable onCompleted)
Deprecated. |
void |
start(Task onCompleted)
Starts the service. |
void |
stop(Runnable onCompleted)
Deprecated. |
void |
stop(Task onCompleted)
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 PipeTransport(PipeTransportServer server)
Method Detail |
---|
public DispatchQueue getDispatchQueue()
Transport
getDispatchQueue
in interface Transport
public void setDispatchQueue(DispatchQueue queue)
Transport
setDispatchQueue
in interface Transport
@Deprecated public void start(Runnable onCompleted)
Transport
start
in interface Transport
onCompleted
- my be set to null if not interested in a callback.public void start(Task onCompleted)
Transport
start
in interface Transport
onCompleted
- my be set to null if not interested in a callback.public void flush()
Transport
flush
in interface Transport
@Deprecated public void stop(Runnable onCompleted)
Transport
stop
in interface Transport
onCompleted
- my be set to null if not interested in a callback.public void stop(Task onCompleted)
Transport
stop
in interface Transport
onCompleted
- my be set to null if not interested in a callback.public boolean full()
full
in interface Transport
public boolean offer(Object command)
Transport
offer
in interface Transport
public void drainInbound()
drainInbound
in interface Transport
public long getWriteCounter()
public long getReadCounter()
public SocketAddress getLocalAddress()
getLocalAddress
in interface Transport
public SocketAddress getRemoteAddress()
getRemoteAddress
in interface Transport
public void suspendRead()
Transport
suspendRead
in interface Transport
public void resumeRead()
Transport
resumeRead
in interface Transport
public void setRemoteAddress(String remoteAddress)
public void setName(String name)
public TransportListener getTransportListener()
Transport
getTransportListener
in interface Transport
public void setTransportListener(TransportListener transportListener)
Transport
setTransportListener
in interface Transport
public ProtocolCodec getProtocolCodec()
getProtocolCodec
in interface Transport
public void setProtocolCodec(ProtocolCodec protocolCodec)
Transport
setProtocolCodec
in interface Transport
public boolean isTrace()
public void setTrace(boolean trace)
public boolean isMarshal()
public void setMarshal(boolean marshall)
public boolean isConnected()
isConnected
in interface Transport
public boolean isClosed()
isClosed
in interface Transport
public Executor getBlockingExecutor()
getBlockingExecutor
in interface Transport
public void setBlockingExecutor(Executor blockingExecutor)
setBlockingExecutor
in interface Transport
public ReadableByteChannel getReadChannel()
getReadChannel
in interface Transport
public WritableByteChannel getWriteChannel()
getWriteChannel
in interface Transport
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |