public abstract class ProxyConnection extends AbstractConnection
AbstractConnection.FillingInterestedCallback, AbstractConnection.NestedState, AbstractConnection.State
Connection.Listener
Modifier and Type | Field and Description |
---|---|
protected static Logger |
LOG |
EXECUTE_ONFILLABLE, FILL_INTERESTED, FILLING, FILLING_FILL_INTERESTED, IDLE, REFILLING
Modifier | Constructor and Description |
---|---|
protected |
ProxyConnection(EndPoint endp,
Executor executor,
ByteBufferPool bufferPool,
ConcurrentMap<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
ByteBufferPool |
getByteBufferPool() |
Connection |
getConnection() |
ConcurrentMap<String,Object> |
getContext() |
void |
onFillable()
Callback method invoked when the endpoint is ready to be read.
|
protected abstract int |
read(EndPoint endPoint,
ByteBuffer buffer) |
void |
setConnection(Connection connection) |
String |
toString() |
protected abstract void |
write(EndPoint endPoint,
ByteBuffer buffer,
Callback callback) |
addListener, close, failedCallback, fillInterested, fillInterested, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, getMessagesIn, getMessagesOut, next, onClose, onFillInterestedFailed, onOpen, onReadTimeout, setInputBufferSize
protected static final Logger LOG
protected ProxyConnection(EndPoint endp, Executor executor, ByteBufferPool bufferPool, ConcurrentMap<String,Object> context)
public ByteBufferPool getByteBufferPool()
public ConcurrentMap<String,Object> getContext()
public Connection getConnection()
public void setConnection(Connection connection)
public void onFillable()
AbstractConnection
Callback method invoked when the endpoint is ready to be read.
onFillable
in class AbstractConnection
AbstractConnection.fillInterested()
protected abstract int read(EndPoint endPoint, ByteBuffer buffer) throws IOException
IOException
protected abstract void write(EndPoint endPoint, ByteBuffer buffer, Callback callback)
public String toString()
toString
in class AbstractConnection
Copyright © 1995-2015 Webtide. All Rights Reserved.