public class ProxyConnectionFactory.ProxyProtocolV2Connection extends AbstractConnection
Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo| Modifier and Type | Field and Description |
|---|---|
private java.nio.ByteBuffer |
_buffer |
private Connector |
_connector |
private ProxyConnectionFactory.Family |
_family |
private int |
_length |
private boolean |
_local |
private java.lang.String |
_next |
private ProxyConnectionFactory.Transport |
_transport |
| Modifier | Constructor and Description |
|---|---|
protected |
ProxyProtocolV2Connection(EndPoint endp,
Connector connector,
java.lang.String next,
java.nio.ByteBuffer buffer) |
| Modifier and Type | Method and Description |
|---|---|
private void |
next() |
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 final boolean _local
private final ProxyConnectionFactory.Family _family
private final ProxyConnectionFactory.Transport _transport
private final int _length
private final 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()private void next()