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, tryFillInterested
private 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()
Connection
Callback method invoked when this connection is opened.
Creators of the connection implementation are responsible for calling this method.
onOpen
in interface Connection
onOpen
in class AbstractConnection
public void onFillable()
AbstractConnection
Callback method invoked when the endpoint is ready to be read.
onFillable
in class AbstractConnection
AbstractConnection.fillInterested()
private void next()