org.apache.qpid.server.protocol.v0_10

Class ServerSessionDelegate

java.lang.Object

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

org.apache.qpid.transport.SessionDelegate

org.apache.qpid.server.protocol.v0_10.ServerSessionDelegate

All Implemented Interfaces:

ProtocolDelegate<Session>

public class ServerSessionDelegate
extends SessionDelegate

Constructor Summary

Constructors

Constructor and Description
ServerSessionDelegate()

Method Summary

Modifier and Type	Method and Description
void	closed(Session session)
void	command(Session session, Method method)
void	detached(Session session)
void	dtxCommit(Session session, DtxCommit method)
void	dtxEnd(Session session, DtxEnd method)
void	dtxForget(Session session, DtxForget method)
void	dtxGetTimeout(Session session, DtxGetTimeout method)
void	dtxPrepare(Session session, DtxPrepare method)
void	dtxRecover(Session session, DtxRecover method)
void	dtxRollback(Session session, DtxRollback method)
void	dtxSelect(Session session, DtxSelect method)
void	dtxSetTimeout(Session session, DtxSetTimeout method)
void	dtxStart(Session session, DtxStart method)
void	exchangeBind(Session session, ExchangeBind method)
void	exchangeBound(Session session, ExchangeBound method)
void	exchangeDeclare(Session session, ExchangeDeclare method)
void	exchangeDelete(Session session, ExchangeDelete method)
void	exchangeQuery(Session session, ExchangeQuery method)
void	exchangeUnbind(Session session, ExchangeUnbind method)
void	executionSync(Session ssn, ExecutionSync sync)
void	messageAccept(Session session, MessageAccept method)
void	messageAcquire(Session session, MessageAcquire method)
void	messageCancel(Session session, MessageCancel method)
void	messageFlow(Session session, MessageFlow flow)
void	messageFlush(Session session, MessageFlush method)
void	messageReject(Session session, MessageReject method)
void	messageRelease(Session session, MessageRelease method)
void	messageResume(Session session, MessageResume method)
void	messageSetFlowMode(Session session, MessageSetFlowMode sfm)
void	messageStop(Session session, MessageStop stop)
void	messageSubscribe(Session session, MessageSubscribe method)
void	messageTransfer(Session ssn, MessageTransfer xfr)
void	queueDeclare(Session session, QueueDeclare method)
void	queueDelete(Session session, QueueDelete method)
void	queuePurge(Session session, QueuePurge method)
void	queueQuery(Session session, QueueQuery method)
void	txCommit(Session session, TxCommit method)
void	txRollback(Session session, TxRollback method)
void	txSelect(Session session, TxSelect method)
protected boolean	verifySessionAccess(ServerSession session, Collection<MessageSource> queues)
protected boolean	verifySessionAccess(ServerSession session, MessageSource queue)

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

command, control, error, executionException, executionResult, handle, init, sessionAttached, sessionCommandPoint, sessionCompleted, sessionFlush, sessionKnownCompleted, sessionRequestTimeout, sessionTimeout

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

connectionClose, connectionCloseOk, connectionHeartbeat, connectionOpen, connectionOpenOk, connectionRedirect, connectionSecure, connectionSecureOk, connectionStart, connectionStartOk, connectionTune, connectionTuneOk, sessionAttach, sessionConfirmed, sessionDetach, sessionDetached, sessionExpected, sessionGap

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ServerSessionDelegate

public ServerSessionDelegate()

Method Detail

command

public void command(Session session,
                    Method method)

Specified by:

command in interface ProtocolDelegate<Session>

Overrides:

command in class SessionDelegate

messageAccept

public void messageAccept(Session session,
                          MessageAccept method)

Overrides:

messageAccept in class MethodDelegate<Session>

messageReject

public void messageReject(Session session,
                          MessageReject method)

Overrides:

messageReject in class MethodDelegate<Session>

messageRelease

public void messageRelease(Session session,
                           MessageRelease method)

Overrides:

messageRelease in class MethodDelegate<Session>

messageAcquire

public void messageAcquire(Session session,
                           MessageAcquire method)

Overrides:

messageAcquire in class MethodDelegate<Session>

messageResume

public void messageResume(Session session,
                          MessageResume method)

Overrides:

messageResume in class MethodDelegate<Session>

messageSubscribe

public void messageSubscribe(Session session,
                             MessageSubscribe method)

Overrides:

messageSubscribe in class MethodDelegate<Session>

verifySessionAccess

protected boolean verifySessionAccess(ServerSession session,
                                      Collection<MessageSource> queues)

verifySessionAccess

protected boolean verifySessionAccess(ServerSession session,
                                      MessageSource queue)

messageTransfer

public void messageTransfer(Session ssn,
                            MessageTransfer xfr)

Overrides:

messageTransfer in class SessionDelegate

messageCancel

public void messageCancel(Session session,
                          MessageCancel method)

Overrides:

messageCancel in class MethodDelegate<Session>

messageFlush

public void messageFlush(Session session,
                         MessageFlush method)

Overrides:

messageFlush in class MethodDelegate<Session>

txSelect

public void txSelect(Session session,
                     TxSelect method)

Overrides:

txSelect in class MethodDelegate<Session>

txCommit

public void txCommit(Session session,
                     TxCommit method)

Overrides:

txCommit in class MethodDelegate<Session>

txRollback

public void txRollback(Session session,
                       TxRollback method)

Overrides:

txRollback in class MethodDelegate<Session>

dtxSelect

public void dtxSelect(Session session,
                      DtxSelect method)

Overrides:

dtxSelect in class MethodDelegate<Session>

dtxStart

public void dtxStart(Session session,
                     DtxStart method)

Overrides:

dtxStart in class MethodDelegate<Session>

dtxEnd

public void dtxEnd(Session session,
                   DtxEnd method)

Overrides:

dtxEnd in class MethodDelegate<Session>

dtxCommit

public void dtxCommit(Session session,
                      DtxCommit method)

Overrides:

dtxCommit in class MethodDelegate<Session>

dtxForget

public void dtxForget(Session session,
                      DtxForget method)

Overrides:

dtxForget in class MethodDelegate<Session>

dtxGetTimeout

public void dtxGetTimeout(Session session,
                          DtxGetTimeout method)

Overrides:

dtxGetTimeout in class MethodDelegate<Session>

dtxPrepare

public void dtxPrepare(Session session,
                       DtxPrepare method)

Overrides:

dtxPrepare in class MethodDelegate<Session>

dtxRecover

public void dtxRecover(Session session,
                       DtxRecover method)

Overrides:

dtxRecover in class MethodDelegate<Session>

dtxRollback

public void dtxRollback(Session session,
                        DtxRollback method)

Overrides:

dtxRollback in class MethodDelegate<Session>

dtxSetTimeout

public void dtxSetTimeout(Session session,
                          DtxSetTimeout method)

Overrides:

dtxSetTimeout in class MethodDelegate<Session>

executionSync

public void executionSync(Session ssn,
                          ExecutionSync sync)

Overrides:

executionSync in class SessionDelegate

exchangeDeclare

public void exchangeDeclare(Session session,
                            ExchangeDeclare method)

Overrides:

exchangeDeclare in class MethodDelegate<Session>

exchangeDelete

public void exchangeDelete(Session session,
                           ExchangeDelete method)

Overrides:

exchangeDelete in class MethodDelegate<Session>

exchangeQuery

public void exchangeQuery(Session session,
                          ExchangeQuery method)

Overrides:

exchangeQuery in class MethodDelegate<Session>

exchangeBind

public void exchangeBind(Session session,
                         ExchangeBind method)

Overrides:

exchangeBind in class MethodDelegate<Session>

exchangeUnbind

public void exchangeUnbind(Session session,
                           ExchangeUnbind method)

Overrides:

exchangeUnbind in class MethodDelegate<Session>

exchangeBound

public void exchangeBound(Session session,
                          ExchangeBound method)

Overrides:

exchangeBound in class MethodDelegate<Session>

queueDeclare

public void queueDeclare(Session session,
                         QueueDeclare method)

Overrides:

queueDeclare in class MethodDelegate<Session>

queueDelete

public void queueDelete(Session session,
                        QueueDelete method)

Overrides:

queueDelete in class MethodDelegate<Session>

queuePurge

public void queuePurge(Session session,
                       QueuePurge method)

Overrides:

queuePurge in class MethodDelegate<Session>

queueQuery

public void queueQuery(Session session,
                       QueueQuery method)

Overrides:

queueQuery in class MethodDelegate<Session>

messageSetFlowMode

public void messageSetFlowMode(Session session,
                               MessageSetFlowMode sfm)

Overrides:

messageSetFlowMode in class SessionDelegate

messageStop

public void messageStop(Session session,
                        MessageStop stop)

Overrides:

messageStop in class SessionDelegate

messageFlow

public void messageFlow(Session session,
                        MessageFlow flow)

Overrides:

messageFlow in class SessionDelegate

closed

public void closed(Session session)

Overrides:

closed in class SessionDelegate

detached

public void detached(Session session)

Overrides:

detached in class SessionDelegate