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

[*] add example with persistent delivery mode

This commit is contained in:
fuCtor 2012-07-25 06:21:26 -07:00
parent a03c19cc8f
commit 0a7dc59c27
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/test.cpp
View File

@ -35,7 +35,10 @@ void Test::declared()
qDebug("\t-= Ready =-"); qDebug("\t-= Ready =-");
//queue_->purge(); //queue_->purge();
exchange_->publish("123", exchange_->name()); 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_->remove(true, false, false);
queue_->setQOS(0,10); queue_->setQOS(0,10);
queue_->setConsumerTag("qamqp-consumer"); queue_->setConsumerTag("qamqp-consumer");