org.apache.qpid.server.handler
Class QueueDeclareHandler

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

public class QueueDeclareHandler
extends Object
implements StateAwareMethodListener<org.apache.qpid.framing.QueueDeclareBody>


Field Summary
 boolean autoRegister
           
 
Constructor Summary
QueueDeclareHandler()
           
 
Method Summary
protected  org.apache.qpid.framing.AMQShortString createName()
           
protected  AMQQueue createQueue(org.apache.qpid.framing.AMQShortString queueName, org.apache.qpid.framing.QueueDeclareBody body, VirtualHost virtualHost, AMQProtocolSession session)
           
static QueueDeclareHandler getInstance()
           
 void methodReceived(AMQStateManager stateManager, org.apache.qpid.framing.QueueDeclareBody body, int channelId)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

autoRegister

public boolean autoRegister
Constructor Detail

QueueDeclareHandler

public QueueDeclareHandler()
Method Detail

getInstance

public static QueueDeclareHandler getInstance()

methodReceived

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

createName

protected org.apache.qpid.framing.AMQShortString createName()

createQueue

protected AMQQueue createQueue(org.apache.qpid.framing.AMQShortString queueName,
                               org.apache.qpid.framing.QueueDeclareBody body,
                               VirtualHost virtualHost,
                               AMQProtocolSession session)
                        throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException


Licensed to the Apache Software Foundation