public abstract class ProxyConnection extends AbstractConnection
Connection.Listener
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,
ConcurrentMap<String,Object> context) |
void |
setConnection(Connection connection) |
String |
toString() |
protected abstract void |
write(EndPoint endPoint,
ByteBuffer buffer,
ConcurrentMap<String,Object> context,
Callback<Void> callback) |
addListener, close, fillInterested, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, getMessagesIn, getMessagesOut, 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, ConcurrentMap<String,Object> context) throws IOException
IOException
protected abstract void write(EndPoint endPoint, ByteBuffer buffer, ConcurrentMap<String,Object> context, Callback<Void> callback)
public String toString()
toString
in class AbstractConnection
Copyright © 1995-2012 Mort Bay Consulting. All Rights Reserved.