public class ConnectHandler.DownstreamConnection extends ProxyConnection
AbstractConnection.FillingInterestedCallback, AbstractConnection.NestedState, AbstractConnection.StateConnection.ListenerLOGEXECUTE_ONFILLABLE, FILL_INTERESTED, FILLING, FILLING_FILL_INTERESTED, IDLE, REFILLING| Constructor and Description |
|---|
ConnectHandler.DownstreamConnection(EndPoint endPoint,
Executor executor,
ByteBufferPool bufferPool,
ConcurrentMap<String,Object> context,
ByteBuffer buffer) |
| Modifier and Type | Method and Description |
|---|---|
void |
onOpen()
Callback method invoked when this
Connection is opened. |
protected int |
read(EndPoint endPoint,
ByteBuffer buffer) |
protected void |
write(EndPoint endPoint,
ByteBuffer buffer,
Callback callback) |
getByteBufferPool, getConnection, getContext, onFillable, setConnection, toStringaddListener, close, failedCallback, fillInterested, fillInterested, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, getMessagesIn, getMessagesOut, next, onClose, onFillInterestedFailed, onReadTimeout, setInputBufferSizepublic ConnectHandler.DownstreamConnection(EndPoint endPoint, Executor executor, ByteBufferPool bufferPool, ConcurrentMap<String,Object> context, ByteBuffer buffer)
public void onOpen()
ConnectionCallback method invoked when this Connection is opened.
Creators of the connection implementation are responsible for calling this method.
onOpen in interface ConnectiononOpen in class AbstractConnectionprotected int read(EndPoint endPoint, ByteBuffer buffer) throws IOException
read in class ProxyConnectionIOExceptionprotected void write(EndPoint endPoint, ByteBuffer buffer, Callback callback)
write in class ProxyConnectionCopyright © 1995-2015 Webtide. All Rights Reserved.