jessequ
/
AMQP-CPP
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fixes issue #119

This commit is contained in:
Emiel Bruijntjes 2017-03-11 17:52:57 +01:00 committed by GitHub
parent 8b8747e216
commit 916f5f6b7c
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
README.md
View File

@ -855,7 +855,7 @@ auto startCb = [](const std::string &consumertag) {
auto errorCb = [](const char *message) { auto errorCb = [](const char *message) {
std::cout << "consume operation failed" << std::endl; std::cout << "consume operation failed" << std::endl;
} };
// callback operation when a message was received // callback operation when a message was received
auto messageCb = [&channel](const AMQP::Message &message, uint64_t deliveryTag, bool redelivered) { auto messageCb = [&channel](const AMQP::Message &message, uint64_t deliveryTag, bool redelivered) {
@ -864,7 +864,7 @@ auto messageCb = [&channel](const AMQP::Message &message, uint64_t deliveryTag,
// acknowledge the message // acknowledge the message
channel.ack(deliveryTag); channel.ack(deliveryTag);
} };
// start consuming from the queue, and install the callbacks // start consuming from the queue, and install the callbacks
channel.consume("my-queue") channel.consume("my-queue")