org.apache.qpid.server.transport
Class ServerConnectionDelegate

java.lang.Object
  extended by org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Connection>
      extended by org.apache.qpid.transport.ConnectionDelegate
          extended by org.apache.qpid.transport.ServerDelegate
              extended by org.apache.qpid.server.transport.ServerConnectionDelegate
All Implemented Interfaces:
org.apache.qpid.transport.ProtocolDelegate<org.apache.qpid.transport.Connection>

public class ServerConnectionDelegate
extends org.apache.qpid.transport.ServerDelegate


Constructor Summary
ServerConnectionDelegate(IApplicationRegistry appRegistry, String localFQDN)
           
ServerConnectionDelegate(Map<String,Object> properties, List<Object> locales, IApplicationRegistry appRegistry, String localFQDN)
           
 
Method Summary
 void connectionOpen(org.apache.qpid.transport.Connection conn, org.apache.qpid.transport.ConnectionOpen open)
           
protected  SaslServer createSaslServer(String mechanism)
           
protected  int getHeartbeatMax()
           
 ServerSession getSession(org.apache.qpid.transport.Connection conn, org.apache.qpid.transport.SessionAttach atc)
           
 
Methods inherited from class org.apache.qpid.transport.ServerDelegate
connectionSecureOk, connectionStartOk, connectionTuneOk, getSession, init, sessionAttach
 
Methods inherited from class org.apache.qpid.transport.ConnectionDelegate
command, connectionClose, connectionCloseOk, connectionHeartbeat, control, error, handle, sessionDetach, sessionDetached
 
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
 

Constructor Detail

ServerConnectionDelegate

public ServerConnectionDelegate(IApplicationRegistry appRegistry,
                                String localFQDN)

ServerConnectionDelegate

public ServerConnectionDelegate(Map<String,Object> properties,
                                List<Object> locales,
                                IApplicationRegistry appRegistry,
                                String localFQDN)
Method Detail

getSession

public ServerSession getSession(org.apache.qpid.transport.Connection conn,
                                org.apache.qpid.transport.SessionAttach atc)
Overrides:
getSession in class org.apache.qpid.transport.ServerDelegate

createSaslServer

protected SaslServer createSaslServer(String mechanism)
                               throws SaslException
Overrides:
createSaslServer in class org.apache.qpid.transport.ServerDelegate
Throws:
SaslException

connectionOpen

public void connectionOpen(org.apache.qpid.transport.Connection conn,
                           org.apache.qpid.transport.ConnectionOpen open)
Overrides:
connectionOpen in class org.apache.qpid.transport.ServerDelegate

getHeartbeatMax

protected int getHeartbeatMax()
Overrides:
getHeartbeatMax in class org.apache.qpid.transport.ServerDelegate


Licensed to the Apache Software Foundation