org.apache.qpid.server.transport
Class ServerSessionDelegate

java.lang.Object
  extended by org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>
      extended by org.apache.qpid.transport.SessionDelegate
          extended by org.apache.qpid.server.transport.ServerSessionDelegate
All Implemented Interfaces:
org.apache.qpid.transport.ProtocolDelegate<org.apache.qpid.transport.Session>

public class ServerSessionDelegate
extends org.apache.qpid.transport.SessionDelegate


Field Summary
 
Fields inherited from class org.apache.qpid.transport.SessionDelegate
log
 
Constructor Summary
ServerSessionDelegate(IApplicationRegistry appRegistry)
           
 
Method Summary
 void closed(org.apache.qpid.transport.Session session)
           
 void command(org.apache.qpid.transport.Session session, org.apache.qpid.transport.Method method)
           
protected  AMQQueue createQueue(String queueName, org.apache.qpid.transport.QueueDeclare body, VirtualHost virtualHost, ServerSession session)
           
 void detached(org.apache.qpid.transport.Session session)
           
 void exchangeBind(org.apache.qpid.transport.Session session, org.apache.qpid.transport.ExchangeBind method)
           
 void exchangeBound(org.apache.qpid.transport.Session session, org.apache.qpid.transport.ExchangeBound method)
           
 void exchangeDeclare(org.apache.qpid.transport.Session session, org.apache.qpid.transport.ExchangeDeclare method)
           
 void exchangeDelete(org.apache.qpid.transport.Session session, org.apache.qpid.transport.ExchangeDelete method)
           
 void exchangeQuery(org.apache.qpid.transport.Session session, org.apache.qpid.transport.ExchangeQuery method)
           
 void exchangeUnbind(org.apache.qpid.transport.Session session, org.apache.qpid.transport.ExchangeUnbind method)
           
 Collection<Subscription_0_10> getSubscriptions(org.apache.qpid.transport.Session session)
           
 void messageAccept(org.apache.qpid.transport.Session session, org.apache.qpid.transport.MessageAccept method)
           
 void messageAcquire(org.apache.qpid.transport.Session session, org.apache.qpid.transport.MessageAcquire method)
           
 void messageCancel(org.apache.qpid.transport.Session session, org.apache.qpid.transport.MessageCancel method)
           
 void messageFlow(org.apache.qpid.transport.Session session, org.apache.qpid.transport.MessageFlow flow)
           
 void messageFlush(org.apache.qpid.transport.Session session, org.apache.qpid.transport.MessageFlush method)
           
 void messageReject(org.apache.qpid.transport.Session session, org.apache.qpid.transport.MessageReject method)
           
 void messageRelease(org.apache.qpid.transport.Session session, org.apache.qpid.transport.MessageRelease method)
           
 void messageResume(org.apache.qpid.transport.Session session, org.apache.qpid.transport.MessageResume method)
           
 void messageSetFlowMode(org.apache.qpid.transport.Session session, org.apache.qpid.transport.MessageSetFlowMode sfm)
           
 void messageStop(org.apache.qpid.transport.Session session, org.apache.qpid.transport.MessageStop stop)
           
 void messageSubscribe(org.apache.qpid.transport.Session session, org.apache.qpid.transport.MessageSubscribe method)
           
 void messageTransfer(org.apache.qpid.transport.Session ssn, org.apache.qpid.transport.MessageTransfer xfr)
           
 void queueDeclare(org.apache.qpid.transport.Session session, org.apache.qpid.transport.QueueDeclare method)
           
 void queueDelete(org.apache.qpid.transport.Session session, org.apache.qpid.transport.QueueDelete method)
           
 void queuePurge(org.apache.qpid.transport.Session session, org.apache.qpid.transport.QueuePurge method)
           
 void queueQuery(org.apache.qpid.transport.Session session, org.apache.qpid.transport.QueueQuery method)
           
 void txCommit(org.apache.qpid.transport.Session session, org.apache.qpid.transport.TxCommit method)
           
 void txRollback(org.apache.qpid.transport.Session session, org.apache.qpid.transport.TxRollback method)
           
 void txSelect(org.apache.qpid.transport.Session session, org.apache.qpid.transport.TxSelect method)
           
 
Methods inherited from class org.apache.qpid.transport.SessionDelegate
control, error, executionException, executionResult, executionSync, 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, dtxCommit, dtxEnd, dtxForget, dtxGetTimeout, dtxPrepare, dtxRecover, dtxRollback, dtxSelect, dtxSetTimeout, dtxStart, 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(IApplicationRegistry appRegistry)
Method Detail

command

public void command(org.apache.qpid.transport.Session session,
                    org.apache.qpid.transport.Method method)
Specified by:
command in interface org.apache.qpid.transport.ProtocolDelegate<org.apache.qpid.transport.Session>
Overrides:
command in class org.apache.qpid.transport.SessionDelegate

messageAccept

public void messageAccept(org.apache.qpid.transport.Session session,
                          org.apache.qpid.transport.MessageAccept method)
Overrides:
messageAccept in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

messageReject

public void messageReject(org.apache.qpid.transport.Session session,
                          org.apache.qpid.transport.MessageReject method)
Overrides:
messageReject in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

messageRelease

public void messageRelease(org.apache.qpid.transport.Session session,
                           org.apache.qpid.transport.MessageRelease method)
Overrides:
messageRelease in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

messageAcquire

public void messageAcquire(org.apache.qpid.transport.Session session,
                           org.apache.qpid.transport.MessageAcquire method)
Overrides:
messageAcquire in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

messageResume

public void messageResume(org.apache.qpid.transport.Session session,
                          org.apache.qpid.transport.MessageResume method)
Overrides:
messageResume in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

messageSubscribe

public void messageSubscribe(org.apache.qpid.transport.Session session,
                             org.apache.qpid.transport.MessageSubscribe method)
Overrides:
messageSubscribe in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

messageTransfer

public void messageTransfer(org.apache.qpid.transport.Session ssn,
                            org.apache.qpid.transport.MessageTransfer xfr)
Overrides:
messageTransfer in class org.apache.qpid.transport.SessionDelegate

messageCancel

public void messageCancel(org.apache.qpid.transport.Session session,
                          org.apache.qpid.transport.MessageCancel method)
Overrides:
messageCancel in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

messageFlush

public void messageFlush(org.apache.qpid.transport.Session session,
                         org.apache.qpid.transport.MessageFlush method)
Overrides:
messageFlush in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

txSelect

public void txSelect(org.apache.qpid.transport.Session session,
                     org.apache.qpid.transport.TxSelect method)
Overrides:
txSelect in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

txCommit

public void txCommit(org.apache.qpid.transport.Session session,
                     org.apache.qpid.transport.TxCommit method)
Overrides:
txCommit in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

txRollback

public void txRollback(org.apache.qpid.transport.Session session,
                       org.apache.qpid.transport.TxRollback method)
Overrides:
txRollback in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

exchangeDeclare

public void exchangeDeclare(org.apache.qpid.transport.Session session,
                            org.apache.qpid.transport.ExchangeDeclare method)
Overrides:
exchangeDeclare in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

exchangeDelete

public void exchangeDelete(org.apache.qpid.transport.Session session,
                           org.apache.qpid.transport.ExchangeDelete method)
Overrides:
exchangeDelete in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

exchangeQuery

public void exchangeQuery(org.apache.qpid.transport.Session session,
                          org.apache.qpid.transport.ExchangeQuery method)
Overrides:
exchangeQuery in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

exchangeBind

public void exchangeBind(org.apache.qpid.transport.Session session,
                         org.apache.qpid.transport.ExchangeBind method)
Overrides:
exchangeBind in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

exchangeUnbind

public void exchangeUnbind(org.apache.qpid.transport.Session session,
                           org.apache.qpid.transport.ExchangeUnbind method)
Overrides:
exchangeUnbind in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

exchangeBound

public void exchangeBound(org.apache.qpid.transport.Session session,
                          org.apache.qpid.transport.ExchangeBound method)
Overrides:
exchangeBound in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

queueDeclare

public void queueDeclare(org.apache.qpid.transport.Session session,
                         org.apache.qpid.transport.QueueDeclare method)
Overrides:
queueDeclare in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

createQueue

protected AMQQueue createQueue(String queueName,
                               org.apache.qpid.transport.QueueDeclare body,
                               VirtualHost virtualHost,
                               ServerSession session)
                        throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

queueDelete

public void queueDelete(org.apache.qpid.transport.Session session,
                        org.apache.qpid.transport.QueueDelete method)
Overrides:
queueDelete in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

queuePurge

public void queuePurge(org.apache.qpid.transport.Session session,
                       org.apache.qpid.transport.QueuePurge method)
Overrides:
queuePurge in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

queueQuery

public void queueQuery(org.apache.qpid.transport.Session session,
                       org.apache.qpid.transport.QueueQuery method)
Overrides:
queueQuery in class org.apache.qpid.transport.MethodDelegate<org.apache.qpid.transport.Session>

messageSetFlowMode

public void messageSetFlowMode(org.apache.qpid.transport.Session session,
                               org.apache.qpid.transport.MessageSetFlowMode sfm)
Overrides:
messageSetFlowMode in class org.apache.qpid.transport.SessionDelegate

messageStop

public void messageStop(org.apache.qpid.transport.Session session,
                        org.apache.qpid.transport.MessageStop stop)
Overrides:
messageStop in class org.apache.qpid.transport.SessionDelegate

messageFlow

public void messageFlow(org.apache.qpid.transport.Session session,
                        org.apache.qpid.transport.MessageFlow flow)
Overrides:
messageFlow in class org.apache.qpid.transport.SessionDelegate

closed

public void closed(org.apache.qpid.transport.Session session)
Overrides:
closed in class org.apache.qpid.transport.SessionDelegate

detached

public void detached(org.apache.qpid.transport.Session session)
Overrides:
detached in class org.apache.qpid.transport.SessionDelegate

getSubscriptions

public Collection<Subscription_0_10> getSubscriptions(org.apache.qpid.transport.Session session)


Licensed to the Apache Software Foundation