begin to add rabbitmq tutorials

most of these are included in the manual amqp test already, but I wanted
to break them out so users could have a nice example of how to do these
in standalone form, like the python tutorials. Helloworld (tutorial 1) is
also included fully implemented in this commit

qamqp.pro

@@ -1,4 +1,5 @@
 TEMPLATE = subdirs
 SUBDIRS += src \
-           tests
+           tests \
+           tutorials
 CONFIG += ordered

tutorials/helloworld/helloworld.pro

@@ -0,0 +1,4 @@
+TEMPLATE = subdirs
+SUBDIRS = \
+    send \
+    receive

tutorials/helloworld/receive/main.cpp

@@ -0,0 +1,60 @@
+#include <QCoreApplication>
+#include <QDebug>
+
+#include "amqp_client.h"
+#include "amqp_exchange.h"
+#include "amqp_queue.h"
+using namespace QAMQP;
+
+class Receiver : public QObject
+{
+    Q_OBJECT
+public:
+    Receiver(QObject *parent = 0) : QObject(parent) {}
+
+public Q_SLOTS:
+    void start() {
+        connect(&m_client, SIGNAL(connected()), this, SLOT(clientConnected()));
+        m_client.connectToHost();
+    }
+
+private Q_SLOTS:
+    void clientConnected() {
+        Queue *queue = m_client.createQueue("hello");
+        connect(queue, SIGNAL(declared()), this, SLOT(queueDeclared()));
+        queue->declare();
+    }
+
+    void queueDeclared() {
+        Queue *queue = qobject_cast<Queue*>(sender());
+        if (!queue)
+            return;
+
+        connect(queue, SIGNAL(messageReceived()), this, SLOT(messageReceived()));
+        queue->consume(Queue::coNoAck);
+        qDebug() << " [*] Waiting for messages. To exit press CTRL+C";
+    }
+
+    void messageReceived() {
+        Queue *queue = qobject_cast<Queue*>(sender());
+        if (!queue)
+            return;
+
+        Message message = queue->dequeue();
+        qDebug() << " [x] Received " << message.payload();
+    }
+
+private:
+    Client m_client;
+
+};
+
+int main(int argc, char **argv)
+{
+    QCoreApplication app(argc, argv);
+    Receiver receiver;
+    receiver.start();
+    return app.exec();
+}
+
+#include "main.moc"

tutorials/helloworld/receive/receive.pro

@@ -0,0 +1,9 @@
+DEPTH = ../../..
+include($${DEPTH}/qamqp.pri)
+
+TEMPLATE = app
+INCLUDEPATH += $${QAMQP_INCLUDEPATH}
+LIBS += -L$${DEPTH}/src $${QAMQP_LIBS}
+macx:CONFIG -= app_bundle
+
+SOURCES += main.cpp

tutorials/helloworld/send/main.cpp

@@ -0,0 +1,52 @@
+#include <QCoreApplication>
+#include <QTimer>
+#include <QDebug>
+
+#include "amqp_client.h"
+#include "amqp_exchange.h"
+#include "amqp_queue.h"
+using namespace QAMQP;
+
+class Sender : public QObject
+{
+    Q_OBJECT
+public:
+    Sender(QObject *parent = 0) : QObject(parent) {}
+
+public Q_SLOTS:
+    void start() {
+        connect(&m_client, SIGNAL(connected()), this, SLOT(clientConnected()));
+        m_client.connectToHost();
+    }
+
+private Q_SLOTS:
+    void clientConnected() {
+        Queue *queue = m_client.createQueue("hello");
+        connect(queue, SIGNAL(declared()), this, SLOT(queueDeclared()));
+        queue->declare();
+    }
+
+    void queueDeclared() {
+        Queue *queue = qobject_cast<Queue*>(sender());
+        if (!queue)
+            return;
+        Exchange *defaultExchange = m_client.createExchange();
+        defaultExchange->publish("Hello World!", "hello");
+        qDebug() << " [x] Sent 'Hello World!'";
+        QTimer::singleShot(25, qApp, SLOT(quit()));
+    }
+
+private:
+    Client m_client;
+
+};
+
+int main(int argc, char **argv)
+{
+    QCoreApplication app(argc, argv);
+    Sender sender;
+    sender.start();
+    return app.exec();
+}
+
+#include "main.moc"

tutorials/helloworld/send/send.pro

@@ -0,0 +1,9 @@
+DEPTH = ../../..
+include($${DEPTH}/qamqp.pri)
+
+TEMPLATE = app
+INCLUDEPATH += $${QAMQP_INCLUDEPATH}
+LIBS += -L$${DEPTH}/src $${QAMQP_LIBS}
+macx:CONFIG -= app_bundle
+
+SOURCES += main.cpp

tutorials/pubsub/emit_log/emit_log.pro

@@ -0,0 +1,9 @@
+DEPTH = ../../..
+include($${DEPTH}/qamqp.pri)
+
+TEMPLATE = app
+INCLUDEPATH += $${QAMQP_INCLUDEPATH}
+LIBS += -L$${DEPTH}/src $${QAMQP_LIBS}
+macx:CONFIG -= app_bundle
+
+SOURCES += main.cpp

tutorials/pubsub/emit_log/main.cpp

@@ -0,0 +1,9 @@
+#include <QCoreApplication>
+#include <QDebug>
+
+int main(int argc, char **argv)
+{
+    QCoreApplication app(argc, argv);
+    qDebug() << "testing";
+    return EXIT_SUCCESS;
+}

tutorials/pubsub/pubsub.pro

@@ -0,0 +1,4 @@
+TEMPLATE = subdirs
+SUBDIRS = \
+    receive_logs \
+    emit_log

tutorials/pubsub/receive_logs/main.cpp

@@ -0,0 +1,9 @@
+#include <QCoreApplication>
+#include <QDebug>
+
+int main(int argc, char **argv)
+{
+    QCoreApplication app(argc, argv);
+    qDebug() << "testing";
+    return EXIT_SUCCESS;
+}

tutorials/pubsub/receive_logs/receive_logs.pro

@@ -0,0 +1,9 @@
+DEPTH = ../../..
+include($${DEPTH}/qamqp.pri)
+
+TEMPLATE = app
+INCLUDEPATH += $${QAMQP_INCLUDEPATH}
+LIBS += -L$${DEPTH}/src $${QAMQP_LIBS}
+macx:CONFIG -= app_bundle
+
+SOURCES += main.cpp

tutorials/routing/emit_log_direct/emit_log_direct.pro

@@ -0,0 +1,9 @@
+DEPTH = ../../..
+include($${DEPTH}/qamqp.pri)
+
+TEMPLATE = app
+INCLUDEPATH += $${QAMQP_INCLUDEPATH}
+LIBS += -L$${DEPTH}/src $${QAMQP_LIBS}
+macx:CONFIG -= app_bundle
+
+SOURCES += main.cpp

tutorials/routing/emit_log_direct/main.cpp

@@ -0,0 +1,9 @@
+#include <QCoreApplication>
+#include <QDebug>
+
+int main(int argc, char **argv)
+{
+    QCoreApplication app(argc, argv);
+    qDebug() << "testing";
+    return EXIT_SUCCESS;
+}

tutorials/routing/receive_logs_direct/main.cpp

@@ -0,0 +1,9 @@
+#include <QCoreApplication>
+#include <QDebug>
+
+int main(int argc, char **argv)
+{
+    QCoreApplication app(argc, argv);
+    qDebug() << "testing";
+    return EXIT_SUCCESS;
+}

tutorials/routing/receive_logs_direct/receive_logs_direct.pro

@@ -0,0 +1,9 @@
+DEPTH = ../../..
+include($${DEPTH}/qamqp.pri)
+
+TEMPLATE = app
+INCLUDEPATH += $${QAMQP_INCLUDEPATH}
+LIBS += -L$${DEPTH}/src $${QAMQP_LIBS}
+macx:CONFIG -= app_bundle
+
+SOURCES += main.cpp

tutorials/routing/routing.pro

@@ -0,0 +1,4 @@
+TEMPLATE = subdirs
+SUBDIRS = \
+    emit_log_direct \
+    receive_logs_direct

tutorials/rpc/rpc.pro

@@ -0,0 +1,4 @@
+TEMPLATE = subdirs
+SUBDIRS = \
+    rpc_server \
+    rpc_client

tutorials/rpc/rpc_client/main.cpp

@@ -0,0 +1,9 @@
+#include <QCoreApplication>
+#include <QDebug>
+
+int main(int argc, char **argv)
+{
+    QCoreApplication app(argc, argv);
+    qDebug() << "testing";
+    return EXIT_SUCCESS;
+}

tutorials/rpc/rpc_client/rpc_client.pro

@@ -0,0 +1,9 @@
+DEPTH = ../../..
+include($${DEPTH}/qamqp.pri)
+
+TEMPLATE = app
+INCLUDEPATH += $${QAMQP_INCLUDEPATH}
+LIBS += -L$${DEPTH}/src $${QAMQP_LIBS}
+macx:CONFIG -= app_bundle
+
+SOURCES += main.cpp

tutorials/rpc/rpc_server/main.cpp

@@ -0,0 +1,9 @@
+#include <QCoreApplication>
+#include <QDebug>
+
+int main(int argc, char **argv)
+{
+    QCoreApplication app(argc, argv);
+    qDebug() << "testing";
+    return EXIT_SUCCESS;
+}

tutorials/rpc/rpc_server/rpc_server.pro

@@ -0,0 +1,9 @@
+DEPTH = ../../..
+include($${DEPTH}/qamqp.pri)
+
+TEMPLATE = app
+INCLUDEPATH += $${QAMQP_INCLUDEPATH}
+LIBS += -L$${DEPTH}/src $${QAMQP_LIBS}
+macx:CONFIG -= app_bundle
+
+SOURCES += main.cpp

tutorials/topics/emit_log_topic/emit_log_topic.pro

@@ -0,0 +1,9 @@
+DEPTH = ../../..
+include($${DEPTH}/qamqp.pri)
+
+TEMPLATE = app
+INCLUDEPATH += $${QAMQP_INCLUDEPATH}
+LIBS += -L$${DEPTH}/src $${QAMQP_LIBS}
+macx:CONFIG -= app_bundle
+
+SOURCES += main.cpp

tutorials/topics/emit_log_topic/main.cpp

@@ -0,0 +1,9 @@
+#include <QCoreApplication>
+#include <QDebug>
+
+int main(int argc, char **argv)
+{
+    QCoreApplication app(argc, argv);
+    qDebug() << "testing";
+    return EXIT_SUCCESS;
+}

tutorials/topics/receive_logs_topic/main.cpp

@@ -0,0 +1,9 @@
+#include <QCoreApplication>
+#include <QDebug>
+
+int main(int argc, char **argv)
+{
+    QCoreApplication app(argc, argv);
+    qDebug() << "testing";
+    return EXIT_SUCCESS;
+}

tutorials/topics/receive_logs_topic/receive_logs_topic.pro

@@ -0,0 +1,9 @@
+DEPTH = ../../..
+include($${DEPTH}/qamqp.pri)
+
+TEMPLATE = app
+INCLUDEPATH += $${QAMQP_INCLUDEPATH}
+LIBS += -L$${DEPTH}/src $${QAMQP_LIBS}
+macx:CONFIG -= app_bundle
+
+SOURCES += main.cpp

tutorials/topics/topics.pro

@@ -0,0 +1,4 @@
+TEMPLATE = subdirs
+SUBDIRS = \
+    emit_log_topic \
+    receive_logs_topic

tutorials/tutorials.pro

@@ -0,0 +1,8 @@
+TEMPLATE = subdirs
+SUBDIRS = \
+    helloworld \
+    workqueues \
+    pubsub \
+    routing \
+    topics \
+    rpc

tutorials/workqueues/new_task/main.cpp

@@ -0,0 +1,9 @@
+#include <QCoreApplication>
+#include <QDebug>
+
+int main(int argc, char **argv)
+{
+    QCoreApplication app(argc, argv);
+    qDebug() << "testing";
+    return EXIT_SUCCESS;
+}

tutorials/workqueues/new_task/new_task.pro

@@ -0,0 +1,9 @@
+DEPTH = ../../..
+include($${DEPTH}/qamqp.pri)
+
+TEMPLATE = app
+INCLUDEPATH += $${QAMQP_INCLUDEPATH}
+LIBS += -L$${DEPTH}/src $${QAMQP_LIBS}
+macx:CONFIG -= app_bundle
+
+SOURCES += main.cpp

tutorials/workqueues/worker/main.cpp

@@ -0,0 +1,9 @@
+#include <QCoreApplication>
+#include <QDebug>
+
+int main(int argc, char **argv)
+{
+    QCoreApplication app(argc, argv);
+    qDebug() << "testing";
+    return EXIT_SUCCESS;
+}

tutorials/workqueues/worker/worker.pro

@@ -0,0 +1,9 @@
+DEPTH = ../../..
+include($${DEPTH}/qamqp.pri)
+
+TEMPLATE = app
+INCLUDEPATH += $${QAMQP_INCLUDEPATH}
+LIBS += -L$${DEPTH}/src $${QAMQP_LIBS}
+macx:CONFIG -= app_bundle
+
+SOURCES += main.cpp

tutorials/workqueues/workqueues.pro

@@ -0,0 +1,4 @@
+TEMPLATE = subdirs
+SUBDIRS = \
+    new_task \
+    worker