public class ProxyConnectionFactory.ProxyProtocolV1orV2Connection extends AbstractConnection
Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo| Modifier and Type | Field and Description |
|---|---|
private java.nio.ByteBuffer |
_buffer |
private Connector |
_connector |
private java.lang.String |
_next |
| Modifier | Constructor and Description |
|---|---|
protected |
ProxyProtocolV1orV2Connection(EndPoint endp,
Connector connector,
java.lang.String next) |
| Modifier and Type | Method and Description |
|---|---|
void |
onFillable()
Callback method invoked when the endpoint is ready to be read.
|
void |
onOpen()
Callback method invoked when this connection is opened.
|
addListener, close, failedCallback, fillInterested, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, getMessagesIn, getMessagesOut, isFillInterested, onClose, onFillInterestedFailed, onIdleExpired, onReadTimeout, removeListener, setInputBufferSize, toConnectionString, toString, tryFillInterested, tryFillInterestedprivate final Connector _connector
private final java.lang.String _next
private java.nio.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 AbstractConnectionpublic void onFillable()
AbstractConnectionCallback method invoked when the endpoint is ready to be read.
onFillable in class AbstractConnectionAbstractConnection.fillInterested()