public class ClientDelegate extends ConnectionDelegate
Constructor and Description |
---|
ClientDelegate(ConnectionSettings settings) |
Modifier and Type | Method and Description |
---|---|
void |
connectionHeartbeat(Connection conn,
ConnectionHeartbeat hearbeat) |
void |
connectionOpenOk(Connection conn,
ConnectionOpenOk ok) |
void |
connectionRedirect(Connection conn,
ConnectionRedirect redir) |
void |
connectionSecure(Connection conn,
ConnectionSecure secure) |
void |
connectionStart(Connection conn,
ConnectionStart start) |
void |
connectionTune(Connection conn,
ConnectionTune tune) |
protected SaslClient |
createSaslClient(List<Object> brokerMechs) |
ConnectionSettings |
getConnectionSettings() |
void |
init(Connection conn,
ProtocolHeader hdr) |
command, connectionClose, connectionCloseOk, control, error, handle, sendConnectionCloseOkAndCloseSender, sessionDetach, sessionDetached, writerIdle
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
public ClientDelegate(ConnectionSettings settings)
public void init(Connection conn, ProtocolHeader hdr)
public void connectionStart(Connection conn, ConnectionStart start)
connectionStart
in class MethodDelegate<Connection>
protected SaslClient createSaslClient(List<Object> brokerMechs) throws ConnectionException, SaslException
ConnectionException
SaslException
public void connectionSecure(Connection conn, ConnectionSecure secure)
connectionSecure
in class MethodDelegate<Connection>
public void connectionTune(Connection conn, ConnectionTune tune)
connectionTune
in class MethodDelegate<Connection>
public void connectionOpenOk(Connection conn, ConnectionOpenOk ok)
connectionOpenOk
in class MethodDelegate<Connection>
public void connectionRedirect(Connection conn, ConnectionRedirect redir)
connectionRedirect
in class MethodDelegate<Connection>
public void connectionHeartbeat(Connection conn, ConnectionHeartbeat hearbeat)
connectionHeartbeat
in class ConnectionDelegate
public ConnectionSettings getConnectionSettings()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.