qamqp/src/amqp_queue.h

#ifndef amqp_queue_h__
#define amqp_queue_h__

#include <QQueue>

#include "amqp_channel.h"
#include "amqp_message.h"
#include "amqp_global.h"

namespace QAMQP
{

class Client;
class ClientPrivate;
class Exchange;
class QueuePrivate;
class QAMQP_EXPORT Queue : public Channel, public QQueue<Message>
{
    Q_OBJECT
    Q_ENUMS(QueueOptions)
    Q_PROPERTY(int options READ options CONSTANT)
    Q_PROPERTY(QString consumerTag READ consumerTag WRITE setConsumerTag)
    Q_PROPERTY(bool noAck READ noAck WRITE setNoAck)
    Q_ENUMS(QueueOption)
    Q_ENUMS(ConsumeOption)
    Q_ENUMS(RemoveOption)

public:
    enum QueueOption {
        NoOptions = 0x0,
        Passive = 0x01,
        Durable = 0x02,
        Exclusive = 0x04,
        AutoDelete = 0x08,
        NoWait = 0x10
    };
    Q_DECLARE_FLAGS(QueueOptions, QueueOption)
    int options() const;

    enum ConsumeOption {
        coNoLocal = 0x01,
        coNoAck = 0x02,
        coExclusive = 0x04,
        coNoWait = 0x08
    };
    Q_DECLARE_FLAGS(ConsumeOptions, ConsumeOption)

    enum RemoveOption {
        roForce = 0x0,
        roIfUnused = 0x01,
        roIfEmpty = 0x02,
        roNoWait = 0x04
    };
    Q_DECLARE_FLAGS(RemoveOptions, RemoveOption)

    ~Queue();

    void setConsumerTag(const QString &consumerTag);
    QString consumerTag() const;

    void setNoAck(bool noAck);
    bool noAck() const;

    // AMQP Queue
    void declare(int options = Durable|AutoDelete);
    void bind(const QString &exchangeName, const QString &key);
    void bind(Exchange *exchange, const QString &key);
    void unbind(const QString &exchangeName, const QString &key);
    void unbind(Exchange *exchange, const QString &key);
    void purge();
    void remove(int options = roIfUnused|roIfEmpty|roNoWait);

    // AMQP Basic
    void consume(int options = NoOptions);
    void get();
    void ack(const Message &message);

Q_SIGNALS:
    void declared();
    void bound();
    void unbound();
    void removed();
    void messageReceived();
    void empty();
    void purged(int messageCount);

protected:
    // reimp Channel
    virtual void channelOpened();
    virtual void channelClosed();

private:
    explicit Queue(int channelNumber = -1, Client *parent = 0);

    Q_DISABLE_COPY(Queue)
    Q_DECLARE_PRIVATE(Queue)

    friend class Client;
};

} // namespace QAMQP

#endif