org.apache.qpid.server.handler
Class BasicGetMethodHandler

java.lang.Object
  extended by org.apache.qpid.server.handler.BasicGetMethodHandler
All Implemented Interfaces:
StateAwareMethodListener<org.apache.qpid.framing.BasicGetBody>

public class BasicGetMethodHandler
extends Object
implements StateAwareMethodListener<org.apache.qpid.framing.BasicGetBody>


Nested Class Summary
static class BasicGetMethodHandler.GetNoAckSubscription
           
 
Method Summary
static BasicGetMethodHandler getInstance()
           
 void methodReceived(AMQStateManager stateManager, org.apache.qpid.framing.BasicGetBody body, int channelId)
           
static boolean performGet(AMQQueue queue, AMQProtocolSession session, AMQChannel channel, boolean acks)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

getInstance

public static BasicGetMethodHandler getInstance()

methodReceived

public void methodReceived(AMQStateManager stateManager,
                           org.apache.qpid.framing.BasicGetBody body,
                           int channelId)
                    throws org.apache.qpid.AMQException
Specified by:
methodReceived in interface StateAwareMethodListener<org.apache.qpid.framing.BasicGetBody>
Throws:
org.apache.qpid.AMQException

performGet

public static boolean performGet(AMQQueue queue,
                                 AMQProtocolSession session,
                                 AMQChannel channel,
                                 boolean acks)
                          throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException


Licensed to the Apache Software Foundation