#ifndef amqp_queue_p_h__
#define amqp_queue_p_h__

#include <QQueue>
#include "amqp_channel_p.h"

namespace QAMQP
{

class QueuePrivate: public ChannelPrivate
{
public:
    enum MethodId {
        METHOD_ID_ENUM(miDeclare, 10),
        METHOD_ID_ENUM(miBind, 20),
        METHOD_ID_ENUM(miUnbind, 50),
        METHOD_ID_ENUM(miPurge, 30),
        METHOD_ID_ENUM(miDelete, 40)
    };

    QueuePrivate(Queue *q);
    ~QueuePrivate();

    // method handler related
    virtual bool _q_method(const Frame::Method &frame);
    void declareOk(const Frame::Method &frame);
    void deleteOk(const Frame::Method &frame);
    void bindOk(const Frame::Method &frame);
    void unbindOk(const Frame::Method &frame);
    void getOk(const Frame::Method &frame);
    void consumeOk(const Frame::Method &frame);
    void deliver(const Frame::Method &frame);

    QString type;
    Queue::QueueOptions options;
    bool delayedDeclare;
    bool declared;
    bool noAck;
    QString consumerTag;
    QQueue<QPair<QString, QString> > delayedBindings;
    QQueue<MessagePtr> messages;
    bool recievingMessage;

    Q_DECLARE_PUBLIC(Queue)

};

} // namespace QAMQP

#endif // amqp_queue_p_h__