org.apache.qpid.server.cluster.handler
Class LocalQueueDeclareHandler

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

public class LocalQueueDeclareHandler
extends org.apache.qpid.server.handler.QueueDeclareHandler


Field Summary
 
Fields inherited from class org.apache.qpid.server.handler.QueueDeclareHandler
autoRegister
 
Method Summary
protected  java.lang.String createName()
           
protected  org.apache.qpid.server.queue.AMQQueue createQueue(org.apache.qpid.framing.QueueDeclareBody body, org.apache.qpid.server.queue.QueueRegistry registry, org.apache.qpid.server.protocol.AMQProtocolSession session)
           
 
Methods inherited from class org.apache.qpid.server.handler.QueueDeclareHandler
getInstance, methodReceived, pad
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

createName

protected java.lang.String createName()
Overrides:
createName in class org.apache.qpid.server.handler.QueueDeclareHandler

createQueue

protected org.apache.qpid.server.queue.AMQQueue createQueue(org.apache.qpid.framing.QueueDeclareBody body,
                                                            org.apache.qpid.server.queue.QueueRegistry registry,
                                                            org.apache.qpid.server.protocol.AMQProtocolSession session)
                                                     throws org.apache.qpid.AMQException
Overrides:
createQueue in class org.apache.qpid.server.handler.QueueDeclareHandler
Throws:
org.apache.qpid.AMQException