public class PipeTransport extends Object implements Transport
Constructor and Description |
---|
PipeTransport(PipeTransportServer server) |
Modifier and Type | Method and Description |
---|---|
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.
|
public PipeTransport(PipeTransportServer server)
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
public void start(Task onCompleted)
Transport
public void flush()
Transport
@Deprecated public void stop(Runnable onCompleted)
Transport
public void stop(Task onCompleted)
Transport
public boolean offer(Object command)
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 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()
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
Copyright © 2010–2017 FuseSource, Corp.. All rights reserved.