diff --git a/include/amqpcpp/channel.h b/include/amqpcpp/channel.h index 5844609..f30922a 100644 --- a/include/amqpcpp/channel.h +++ b/include/amqpcpp/channel.h @@ -332,7 +332,7 @@ public: * * void myCallback(uint32_t messageCount); * - * For example: channel.declareQueue("myqueue").onSuccess([](uint32_t messageCount) { + * For example: channel.purgeQueue("myqueue").onSuccess([](uint32_t messageCount) { * * std::cout << "Queue purged, all " << messageCount << " messages removed" << std::endl; * diff --git a/include/amqpcpp/channelimpl.h b/include/amqpcpp/channelimpl.h index c7c3ead..963c337 100644 --- a/include/amqpcpp/channelimpl.h +++ b/include/amqpcpp/channelimpl.h @@ -384,7 +384,7 @@ public: * * void myCallback(AMQP::Channel *channel, uint32_t messageCount); * - * For example: channel.declareQueue("myqueue").onSuccess([](AMQP::Channel *channel, uint32_t messageCount) { + * For example: channel.purgeQueue("myqueue").onSuccess([](AMQP::Channel *channel, uint32_t messageCount) { * * std::cout << "Queue purged, all " << messageCount << " messages removed" << std::endl; *