public class ServerDelegate extends ConnectionDelegate
Modifier and Type | Field and Description |
---|---|
protected static org.slf4j.Logger |
_logger |
static int |
MAX_FRAME_SIZE |
Modifier | Constructor and Description |
---|---|
|
ServerDelegate() |
protected |
ServerDelegate(Map<String,Object> clientProperties,
List<Object> mechanisms,
List<Object> locales) |
command, connectionClose, connectionCloseOk, connectionHeartbeat, control, error, handle, sendConnectionCloseOkAndCloseSender, sessionDetach, 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 static final int MAX_FRAME_SIZE
protected static final org.slf4j.Logger _logger
public void init(Connection conn, ProtocolHeader hdr)
public void connectionStartOk(Connection conn, ConnectionStartOk ok)
connectionStartOk
in class MethodDelegate<Connection>
protected SaslServer createSaslServer(Connection conn, String mechanism) throws SaslException
SaslException
protected void secure(SaslServer ss, Connection conn, byte[] response)
protected void connectionAuthFailed(Connection conn, Exception e)
protected void connectionAuthContinue(Connection conn, byte[] challenge)
protected void tuneAuthorizedConnection(Connection conn)
protected int getFrameMax()
protected void secure(Connection conn, byte[] response)
protected int getHeartbeatMax()
protected int getChannelMax()
public void connectionSecureOk(Connection conn, ConnectionSecureOk ok)
connectionSecureOk
in class MethodDelegate<Connection>
public void connectionTuneOk(Connection conn, ConnectionTuneOk ok)
connectionTuneOk
in class MethodDelegate<Connection>
public void connectionOpen(Connection conn, ConnectionOpen open)
connectionOpen
in class MethodDelegate<Connection>
protected Session getSession(Connection conn, SessionDelegate delegate, SessionAttach atc)
public Session getSession(Connection conn, SessionAttach atc)
public void sessionAttach(Connection conn, SessionAttach atc)
sessionAttach
in class MethodDelegate<Connection>
protected void setConnectionTuneOkChannelMax(Connection conn, int okChannelMax)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.