protected abstract static class ProxyProtocolClientConnectionFactory.ProxyProtocolConnection extends AbstractConnection implements Callback
Callback.Completable, Callback.Completing, Callback.InvocableCallback, Callback.Nested
Invocable.InvocationType
Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo
Modifier and Type | Field and Description |
---|---|
private java.util.Map<java.lang.String,java.lang.Object> |
context |
private ClientConnectionFactory |
factory |
protected static Logger |
LOG |
__nonBlocking
Modifier | Constructor and Description |
---|---|
private |
ProxyProtocolConnection(EndPoint endPoint,
java.util.concurrent.Executor executor,
ClientConnectionFactory factory,
java.util.Map<java.lang.String,java.lang.Object> context) |
Modifier and Type | Method and Description |
---|---|
void |
failed(java.lang.Throwable x)
Callback invoked when the operation fails.
|
Invocable.InvocationType |
getInvocationType() |
void |
onFillable()
Callback method invoked when the endpoint is ready to be read.
|
void |
onOpen()
Callback method invoked when this connection is opened.
|
void |
succeeded()
Callback invoked when the operation completes.
|
protected abstract void |
writePROXYBytes(EndPoint endPoint,
Callback callback) |
addListener, close, failedCallback, fillInterested, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, getMessagesIn, getMessagesOut, isFillInterested, onClose, onFillInterestedFailed, onIdleExpired, onReadTimeout, removeListener, setInputBufferSize, toConnectionString, toString, tryFillInterested, tryFillInterested
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
combine, from, from, from, from, from, from
combine, getInvocationType, invokeNonBlocking, isNonBlockingInvocation
protected static final Logger LOG
private final ClientConnectionFactory factory
private final java.util.Map<java.lang.String,java.lang.Object> context
private ProxyProtocolConnection(EndPoint endPoint, java.util.concurrent.Executor executor, ClientConnectionFactory factory, java.util.Map<java.lang.String,java.lang.Object> context)
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 succeeded()
Callback
Callback invoked when the operation completes.
succeeded
in interface Callback
Callback.failed(Throwable)
public void failed(java.lang.Throwable x)
Callback
Callback invoked when the operation fails.
public Invocable.InvocationType getInvocationType()
getInvocationType
in interface Invocable
public void onFillable()
AbstractConnection
Callback method invoked when the endpoint is ready to be read.
onFillable
in class AbstractConnection
AbstractConnection.fillInterested()