public abstract class ProxyConnection extends AbstractConnection
Connection.Listener| Modifier and Type | Field and Description |
|---|---|
protected static Logger |
LOG |
EXECUTE_ONFILLABLE| 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, block, close, fillInterested, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, getMessagesIn, getMessagesOut, onClose, onFillInterestedFailed, onOpen, onReadTimeout, setInputBufferSizeprotected 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()
AbstractConnectionCallback method invoked when the endpoint is ready to be read.
onFillable in class AbstractConnectionAbstractConnection.fillInterested()protected abstract int read(EndPoint endPoint, ByteBuffer buffer) throws IOException
IOExceptionprotected abstract void write(EndPoint endPoint, ByteBuffer buffer, Callback callback)
public String toString()
toString in class AbstractConnectionCopyright © 1995-2019 Mort Bay Consulting. All Rights Reserved.