org.apache.qpid.transport
Class ConnectionDelegate
java.lang.Object
org.apache.qpid.transport.MethodDelegate<Connection>
org.apache.qpid.transport.ConnectionDelegate
- All Implemented Interfaces:
- ProtocolDelegate<Connection>
- Direct Known Subclasses:
- ClientDelegate, ServerDelegate
public abstract class ConnectionDelegate
- extends MethodDelegate<Connection>
- implements ProtocolDelegate<Connection>
Currently only implemented client specific methods
the server specific methods are dummy impls for testing
the connectionClose is kind of different for both sides
Methods inherited from class org.apache.qpid.transport.MethodDelegate |
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 |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ConnectionDelegate
public ConnectionDelegate()
control
public void control(Connection conn,
Method method)
- Specified by:
control
in interface ProtocolDelegate<Connection>
command
public void command(Connection conn,
Method method)
- Specified by:
command
in interface ProtocolDelegate<Connection>
error
public void error(Connection conn,
ProtocolError error)
- Specified by:
error
in interface ProtocolDelegate<Connection>
handle
public void handle(Connection conn,
Method method)
- Specified by:
handle
in class MethodDelegate<Connection>
connectionHeartbeat
public void connectionHeartbeat(Connection conn,
ConnectionHeartbeat hearbeat)
- Overrides:
connectionHeartbeat
in class MethodDelegate<Connection>
connectionClose
public void connectionClose(Connection conn,
ConnectionClose close)
- Overrides:
connectionClose
in class MethodDelegate<Connection>
connectionCloseOk
public void connectionCloseOk(Connection conn,
ConnectionCloseOk ok)
- Overrides:
connectionCloseOk
in class MethodDelegate<Connection>
sessionDetach
public void sessionDetach(Connection conn,
SessionDetach dtc)
- Overrides:
sessionDetach
in class MethodDelegate<Connection>
sessionDetached
public void sessionDetached(Connection conn,
SessionDetached dtc)
- Overrides:
sessionDetached
in class MethodDelegate<Connection>
Licensed to the Apache Software Foundation