qamqp/src/amqp_client.h

#ifndef amqp_client_h__
#define amqp_client_h__

#include <QObject>
#include <QUrl>

#include "amqp_global.h"

namespace QAMQP
{

class Exchange;
class Queue;
class ClientPrivate;
class Authenticator;
class ConnectionPrivate;
class QAMQP_EXPORT Client : public QObject
{
    Q_OBJECT
    Q_PROPERTY(quint32 port READ port WRITE setPort)
    Q_PROPERTY(QString host READ host WRITE setHost)
    Q_PROPERTY(QString virtualHost READ virtualHost WRITE setVirtualHost)
    Q_PROPERTY(QString user READ user WRITE setUser)
    Q_PROPERTY(QString password READ password WRITE setPassword)
    Q_PROPERTY(bool ssl READ isSsl WRITE setSsl)
    Q_PROPERTY(bool autoReconnect READ autoReconnect WRITE setAutoReconnect)
    Q_PROPERTY(bool connected READ isConnected)

public:
    Client(QObject *parent = 0);
    Client(const QUrl &connectionString, QObject *parent = 0);
    ~Client();

    void printConnect() const;
    void closeChannel();

    void addCustomProperty(const QString &name, const QString &value);
    QString customProperty(const QString &name) const;

    Exchange *createExchange(int channelNumber = -1);
    Exchange *createExchange(const QString &name, int channelNumber = -1);

    Queue *createQueue(int channelNumber = -1);
    Queue *createQueue(const QString &name, int channelNumber = -1);

    quint16 port() const;
    void setPort(quint16 port);

    QString host() const;
    void setHost(const QString &host);

    QString virtualHost() const;
    void setVirtualHost(const QString &virtualHost);

    QString user() const;
    void setUser(const QString &user);

    QString password() const;
    void setPassword(const QString &password);

    void setAuth(Authenticator *auth);
    Authenticator *auth() const;

    void open();
    void open(const QUrl &connectionString);
    void close();
    void reopen();

    bool isSsl() const;
    void setSsl(bool value);

    bool autoReconnect() const;
    void setAutoReconnect(bool value);

    bool isConnected() const;

signals:
    void connected();
    void disconnected();

private:
    Q_DISABLE_COPY(Client)
    Q_DECLARE_PRIVATE(QAMQP::Client)
    QScopedPointer<ClientPrivate> d_ptr;

    friend class ConnectionPrivate;
    friend class ChannelPrivate;
};

} // namespace QAMQP

#endif // amqp_client_h__