jessequ
/
qamqp
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

remove old example

This commit is contained in:
Alexey Shcherbakov 2013-02-23 13:43:24 +06:00
parent e56a6afa9d
commit 4efe2c4031
2 changed files with 0 additions and 99 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

74
src/test.cpp
View File

@ -1,74 +0,0 @@
#include "test.h"
#include <QTime>
#include <QFile>
Test::Test()
{
QUrl con(QString("amqp://guest:guest@localhost:5672/"));
client_ = new QAMQP::Client(this);
client_->open(con);
exchange_ = client_->createExchange("test.test2");
exchange_->declare("fanout");
queue_ = client_->createQueue("test.my_queue", exchange_->channelNumber());
queue_->declare();
queue2_ = client_->createQueue("test.my_queue2");
queue2_->declare();
exchange_->bind(queue_);
exchange_->bind(queue2_);
connect(queue2_, SIGNAL(declared()), this, SLOT(declared()));
connect(queue_, SIGNAL(messageReceived()), this, SLOT(newMessage()));
connect(queue2_, SIGNAL(messageReceived()), this, SLOT(newMessage()));
}
Test::~Test()
{
}
void Test::declared()
{
qDebug("\t-= Ready =-");
//queue_->purge();
QAMQP::Exchange::MessageProperties properties;
properties[QAMQP::Frame::Content::cpDeliveryMode] = 2; // Make message persistent
exchange_->publish("123", exchange_->name(), properties);
//queue_->remove(true, false, false);
queue_->setQOS(0,10);
queue_->setConsumerTag("qamqp-consumer");
queue_->consume(QAMQP::Queue::coNoAck);
//queue_->setNoAck(false);
//queue_->get();
queue2_->setQOS(0,10);
queue2_->setConsumerTag("qamqp-consumer2");
queue2_->consume(QAMQP::Queue::coNoAck);
//exchange_->remove(false, false);
}
void Test::newMessage()
{
QAMQP::Queue * q = qobject_cast<QAMQP::Queue *>(sender());
while (q->hasMessage())
{
QAMQP::MessagePtr message = q->getMessage();
qDebug("+ RECEIVE MESSAGE");
qDebug("| Exchange-name: %s", qPrintable(message->exchangeName));
qDebug("| Routing-key: %s", qPrintable(message->routeKey));
qDebug("| Content-type: %s", qPrintable(message->property[QAMQP::Frame::Content::cpContentType].toString()));
if(!q->noAck())
{
q->ack(message);
}
}
}

25
src/test.h
View File

@ -1,25 +0,0 @@
#include <QObject>
#include "qamqp/amqp.h"
#include "qamqp/amqp_exchange.h"
#include "qamqp/amqp_queue.h"
#include <QPointer>
class Test : public QObject
{
Q_OBJECT
public:
Test();
~Test();
Q_INVOKABLE void test() {};
private slots:
void declared();
void newMessage();
private:
QPointer<QAMQP::Client> client_;
QPointer<QAMQP::Exchange> exchange_;
QPointer<QAMQP::Queue> queue_, queue2_;
};