public class ClientConnectionDelegate extends ClientDelegate
Constructor and Description |
---|
ClientConnectionDelegate(ConnectionSettings settings,
ConnectionURL connectionURL) |
Modifier and Type | Method and Description |
---|---|
void |
connectionHeartbeat(Connection conn,
ConnectionHeartbeat heartbeat) |
void |
connectionOpenOk(Connection conn,
ConnectionOpenOk ok) |
protected SaslClient |
createSaslClient(List<Object> brokerMechs) |
void |
setHeartbeatListener(HeartbeatListener listener) |
void |
writerIdle(Connection connection) |
connectionRedirect, connectionSecure, connectionStart, connectionTune, getConnectionSettings, init
command, connectionClose, connectionCloseOk, control, error, handle, sendConnectionCloseOkAndCloseSender, sessionDetach, sessionDetached
connectionOpen, connectionSecureOk, connectionStartOk, connectionTuneOk, dtxCommit, dtxEnd, dtxForget, dtxGetTimeout, dtxPrepare, dtxRecover, dtxRollback, dtxSelect, dtxSetTimeout, dtxStart, exchangeBind, exchangeBound, exchangeDeclare, exchangeDelete, exchangeQuery, exchangeUnbind, executionException, executionResult, executionSync, messageAccept, messageAcquire, messageCancel, messageFlow, messageFlush, messageReject, messageRelease, messageResume, messageSetFlowMode, messageStop, messageSubscribe, messageTransfer, queueDeclare, queueDelete, queuePurge, queueQuery, sessionAttach, sessionAttached, sessionCommandPoint, sessionCompleted, sessionConfirmed, sessionExpected, sessionFlush, sessionGap, sessionKnownCompleted, sessionRequestTimeout, sessionTimeout, txCommit, txRollback, txSelect
protected static final Oid KRB5_OID
public ClientConnectionDelegate(ConnectionSettings settings, ConnectionURL connectionURL)
settings
- connectionURL
- protected SaslClient createSaslClient(List<Object> brokerMechs) throws ConnectionException, SaslException
createSaslClient
in class ClientDelegate
ConnectionException
SaslException
public void connectionOpenOk(Connection conn, ConnectionOpenOk ok)
connectionOpenOk
in class ClientDelegate
public void connectionHeartbeat(Connection conn, ConnectionHeartbeat heartbeat)
connectionHeartbeat
in class ClientDelegate
public void setHeartbeatListener(HeartbeatListener listener)
public void writerIdle(Connection connection)
writerIdle
in class ConnectionDelegate
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.