public abstract class ConnectionDelegate extends MethodDelegate<Connection> implements ProtocolDelegate<Connection>
Constructor and Description |
---|
ConnectionDelegate() |
Modifier and Type | Method and Description |
---|---|
void |
command(Connection conn,
Method method) |
void |
connectionClose(Connection conn,
ConnectionClose close) |
void |
connectionCloseOk(Connection conn,
ConnectionCloseOk ok) |
void |
connectionHeartbeat(Connection conn,
ConnectionHeartbeat hearbeat) |
void |
control(Connection conn,
Method method) |
void |
error(Connection conn,
ProtocolError error) |
void |
handle(Connection conn,
Method method) |
protected void |
sendConnectionCloseOkAndCloseSender(Connection conn) |
void |
sessionDetach(Connection conn,
SessionDetach dtc) |
void |
sessionDetached(Connection conn,
SessionDetached dtc) |
void |
writerIdle(Connection connection) |
connectionOpen, connectionOpenOk, connectionRedirect, connectionSecure, connectionSecureOk, connectionStart, connectionStartOk, connectionTune, 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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
init
public void control(Connection conn, Method method)
control
in interface ProtocolDelegate<Connection>
public void command(Connection conn, Method method)
command
in interface ProtocolDelegate<Connection>
public void error(Connection conn, ProtocolError error)
error
in interface ProtocolDelegate<Connection>
public void handle(Connection conn, Method method)
handle
in class MethodDelegate<Connection>
public void connectionHeartbeat(Connection conn, ConnectionHeartbeat hearbeat)
connectionHeartbeat
in class MethodDelegate<Connection>
public void connectionClose(Connection conn, ConnectionClose close)
connectionClose
in class MethodDelegate<Connection>
protected void sendConnectionCloseOkAndCloseSender(Connection conn)
public void connectionCloseOk(Connection conn, ConnectionCloseOk ok)
connectionCloseOk
in class MethodDelegate<Connection>
public void sessionDetach(Connection conn, SessionDetach dtc)
sessionDetach
in class MethodDelegate<Connection>
public void sessionDetached(Connection conn, SessionDetached dtc)
sessionDetached
in class MethodDelegate<Connection>
public void writerIdle(Connection connection)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.