org.apache.qpid.transport
Class ServerDelegate
java.lang.Object
org.apache.qpid.transport.MethodDelegate<Connection>
org.apache.qpid.transport.ConnectionDelegate
org.apache.qpid.transport.ServerDelegate
- All Implemented Interfaces:
- ProtocolDelegate<Connection>
public class ServerDelegate
- extends ConnectionDelegate
ServerDelegate
Methods inherited from class org.apache.qpid.transport.MethodDelegate |
connectionOpenOk, connectionRedirect, connectionSecure, connectionStart, connectionTune, 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, 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 |
ServerDelegate
public ServerDelegate()
ServerDelegate
protected ServerDelegate(Map<String,Object> clientProperties,
List<Object> mechanisms,
List<Object> locales)
init
public void init(Connection conn,
ProtocolHeader hdr)
connectionStartOk
public void connectionStartOk(Connection conn,
ConnectionStartOk ok)
- Overrides:
connectionStartOk
in class MethodDelegate<Connection>
createSaslServer
protected SaslServer createSaslServer(String mechanism)
throws SaslException
- Throws:
SaslException
getHeartbeatMax
protected int getHeartbeatMax()
connectionSecureOk
public void connectionSecureOk(Connection conn,
ConnectionSecureOk ok)
- Overrides:
connectionSecureOk
in class MethodDelegate<Connection>
connectionTuneOk
public void connectionTuneOk(Connection conn,
ConnectionTuneOk ok)
- Overrides:
connectionTuneOk
in class MethodDelegate<Connection>
connectionOpen
public void connectionOpen(Connection conn,
ConnectionOpen open)
- Overrides:
connectionOpen
in class MethodDelegate<Connection>
getSession
protected Session getSession(Connection conn,
SessionDelegate delegate,
SessionAttach atc)
getSession
public Session getSession(Connection conn,
SessionAttach atc)
sessionAttach
public void sessionAttach(Connection conn,
SessionAttach atc)
- Overrides:
sessionAttach
in class MethodDelegate<Connection>
Licensed to the Apache Software Foundation