public class ServerConnectionDelegate extends ServerDelegate
_logger, MAX_FRAME_SIZE
Constructor and Description |
---|
ServerConnectionDelegate(Broker<?> broker,
String localFQDN,
SubjectCreator subjectCreator) |
connectionAuthContinue, connectionAuthFailed, getSession, secure, setConnectionTuneOkChannelMax, tuneAuthorizedConnection
command, connectionCloseOk, connectionHeartbeat, control, error, handle, sendConnectionCloseOkAndCloseSender, sessionDetached, writerIdle
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
public ServerConnectionDelegate(Broker<?> broker, String localFQDN, SubjectCreator subjectCreator)
public final org.apache.qpid.server.protocol.v0_10.ServerConnectionDelegate.ConnectionState getState()
public void init(Connection conn, ProtocolHeader hdr)
init
in interface ProtocolDelegate<Connection>
init
in class ServerDelegate
public ServerSession getSession(Connection conn, SessionAttach atc)
getSession
in class ServerDelegate
protected SaslServer createSaslServer(Connection conn, String mechanism) throws SaslException
createSaslServer
in class ServerDelegate
SaslException
public void connectionSecureOk(Connection conn, ConnectionSecureOk ok)
connectionSecureOk
in class ServerDelegate
protected void secure(SaslServer ss, Connection conn, byte[] response)
secure
in class ServerDelegate
public void connectionClose(Connection conn, ConnectionClose close)
connectionClose
in class ConnectionDelegate
public void connectionOpen(Connection conn, ConnectionOpen open)
connectionOpen
in class ServerDelegate
public void connectionTuneOk(Connection conn, ConnectionTuneOk ok)
connectionTuneOk
in class ServerDelegate
public int getChannelMax()
getChannelMax
in class ServerDelegate
protected void setChannelMax(int channelMax)
protected int getFrameMax()
getFrameMax
in class ServerDelegate
public void sessionDetach(Connection conn, SessionDetach dtc)
sessionDetach
in class ConnectionDelegate
public void sessionAttach(Connection conn, SessionAttach atc)
sessionAttach
in class ServerDelegate
public void connectionStartOk(Connection conn, ConnectionStartOk ok)
connectionStartOk
in class ServerDelegate
public String getClientId()
public String getClientVersion()
public String getClientProduct()
public String getRemoteProcessPid()
protected int getHeartbeatMax()
getHeartbeatMax
in class ServerDelegate
public boolean isCompressionSupported()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.