org.apache.qpid.server.protocol.v0_10

Class ServerConnectionDelegate

java.lang.Object

org.apache.qpid.transport.MethodDelegate<Connection>

org.apache.qpid.transport.ConnectionDelegate

org.apache.qpid.transport.ServerDelegate

org.apache.qpid.server.protocol.v0_10.ServerConnectionDelegate

All Implemented Interfaces:

ProtocolDelegate<Connection>

public class ServerConnectionDelegate
extends ServerDelegate

Field Summary

Fields inherited from class org.apache.qpid.transport.ServerDelegate

_logger, MAX_FRAME_SIZE

Constructor Summary

Constructors

Constructor and Description
ServerConnectionDelegate(Broker<?> broker, String localFQDN, SubjectCreator subjectCreator)

Method Summary

Modifier and Type	Method and Description
void	connectionClose(Connection conn, ConnectionClose close)
void	connectionOpen(Connection conn, ConnectionOpen open)
void	connectionSecureOk(Connection conn, ConnectionSecureOk ok)
void	connectionStartOk(Connection conn, ConnectionStartOk ok)
void	connectionTuneOk(Connection conn, ConnectionTuneOk ok)
protected SaslServer	createSaslServer(Connection conn, String mechanism)
int	getChannelMax()
String	getClientId()
String	getClientProduct()
Map<String,Object>	getClientProperties()
String	getClientVersion()
protected int	getFrameMax()
protected int	getHeartbeatMax()
String	getRemoteProcessPid()
ServerSession	getSession(Connection conn, SessionAttach atc)
org.apache.qpid.server.protocol.v0_10.ServerConnectionDelegate.ConnectionState	getState()
void	init(Connection conn, ProtocolHeader hdr)
boolean	isCompressionSupported()
protected void	secure(SaslServer ss, Connection conn, byte[] response)
void	sessionAttach(Connection conn, SessionAttach atc)
void	sessionDetach(Connection conn, SessionDetach dtc)
protected void	setChannelMax(int channelMax)

Methods inherited from class org.apache.qpid.transport.ServerDelegate

connectionAuthContinue, connectionAuthFailed, getSession, secure, setConnectionTuneOkChannelMax, tuneAuthorizedConnection

Methods inherited from class org.apache.qpid.transport.ConnectionDelegate

command, connectionCloseOk, connectionHeartbeat, control, error, handle, sendConnectionCloseOkAndCloseSender, sessionDetached, writerIdle

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(Broker<?> broker,
                                String localFQDN,
                                SubjectCreator subjectCreator)

Method Detail

getState

public final org.apache.qpid.server.protocol.v0_10.ServerConnectionDelegate.ConnectionState getState()

init

public void init(Connection conn,
                 ProtocolHeader hdr)

Specified by:

init in interface ProtocolDelegate<Connection>

Overrides:

init in class ServerDelegate

getSession

public ServerSession getSession(Connection conn,
                                SessionAttach atc)

Overrides:

getSession in class ServerDelegate

createSaslServer

protected SaslServer createSaslServer(Connection conn,
                                      String mechanism)
                               throws SaslException

Overrides:

createSaslServer in class ServerDelegate

Throws:

SaslException

connectionSecureOk

public void connectionSecureOk(Connection conn,
                               ConnectionSecureOk ok)

Overrides:

connectionSecureOk in class ServerDelegate

secure

protected void secure(SaslServer ss,
                      Connection conn,
                      byte[] response)

Overrides:

secure in class ServerDelegate

connectionClose

public void connectionClose(Connection conn,
                            ConnectionClose close)

Overrides:

connectionClose in class ConnectionDelegate

connectionOpen

public void connectionOpen(Connection conn,
                           ConnectionOpen open)

Overrides:

connectionOpen in class ServerDelegate

connectionTuneOk

public void connectionTuneOk(Connection conn,
                             ConnectionTuneOk ok)

Overrides:

connectionTuneOk in class ServerDelegate

getChannelMax

public int getChannelMax()

Overrides:

getChannelMax in class ServerDelegate

setChannelMax

protected void setChannelMax(int channelMax)

getFrameMax

protected int getFrameMax()

Overrides:

getFrameMax in class ServerDelegate

sessionDetach

public void sessionDetach(Connection conn,
                          SessionDetach dtc)

Overrides:

sessionDetach in class ConnectionDelegate

sessionAttach

public void sessionAttach(Connection conn,
                          SessionAttach atc)

Overrides:

sessionAttach in class ServerDelegate

connectionStartOk

public void connectionStartOk(Connection conn,
                              ConnectionStartOk ok)

Overrides:

connectionStartOk in class ServerDelegate

getClientProperties

public Map<String,Object> getClientProperties()

getClientId

public String getClientId()

getClientVersion

public String getClientVersion()

getClientProduct

public String getClientProduct()

getRemoteProcessPid

public String getRemoteProcessPid()

getHeartbeatMax

protected int getHeartbeatMax()

Overrides:

getHeartbeatMax in class ServerDelegate

isCompressionSupported

public boolean isCompressionSupported()