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

Channel::get() and Channel::purgeQueue() methods always reported an error, even while there was no error

This commit is contained in:
Emiel Bruijntjes 2014-08-29 13:16:05 +02:00
parent ebcdd71848
commit 8759258a3e
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/channelimpl.cpp
View File

@ -361,7 +361,7 @@ DeferredDelete &ChannelImpl::purgeQueue(const std::string &name)
QueuePurgeFrame frame(_id, name, false); QueuePurgeFrame frame(_id, name, false);
// send the frame, and create deferred object // send the frame, and create deferred object
auto *deferred = new DeferredDelete(send(frame)); auto *deferred = new DeferredDelete(!send(frame));
// push to list // push to list
push(deferred); push(deferred);
@ -582,7 +582,7 @@ DeferredGet &ChannelImpl::get(const std::string &queue, int flags)
BasicGetFrame frame(_id, queue, flags & noack); BasicGetFrame frame(_id, queue, flags & noack);
// send the frame, and create deferred object // send the frame, and create deferred object
auto *deferred = new DeferredGet(this, send(frame)); auto *deferred = new DeferredGet(this, !send(frame));
// push to list // push to list
push(deferred); push(deferred);