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

bug - negate the result of send() before using the result in a DeferredResult constructor

This commit is contained in:
Richard Hodges 2014-07-30 15:29:05 +01:00
parent d2a97c1dd3
commit d4b10cbf35
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/channelimpl.cpp
View File

@ -290,7 +290,7 @@ DeferredQueue &ChannelImpl::declareQueue(const std::string &name, int flags, con
QueueDeclareFrame frame(_id, name, flags & passive, flags & durable, flags & exclusive, flags & autodelete, false, arguments); QueueDeclareFrame frame(_id, name, flags & passive, flags & durable, flags & exclusive, flags & autodelete, false, arguments);
// send the queuedeclareframe // send the queuedeclareframe
auto *result = new DeferredQueue(send(frame)); auto *result = new DeferredQueue(!send(frame));
// add the deferred result // add the deferred result
push(result); push(result);
@ -389,7 +389,7 @@ DeferredDelete &ChannelImpl::removeQueue(const std::string &name, int flags)
QueueDeleteFrame frame(_id, name, flags & ifunused, flags & ifempty, false); QueueDeleteFrame frame(_id, name, flags & ifunused, flags & ifempty, 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);
@ -495,7 +495,7 @@ DeferredConsumer& ChannelImpl::consume(const std::string &queue, const std::stri
BasicConsumeFrame frame(_id, queue, tag, flags & nolocal, flags & noack, flags & exclusive, false, arguments); BasicConsumeFrame frame(_id, queue, tag, flags & nolocal, flags & noack, flags & exclusive, false, arguments);
// send the frame, and create deferred object // send the frame, and create deferred object
auto *deferred = new DeferredConsumer(this, send(frame)); auto *deferred = new DeferredConsumer(this, !send(frame));
// push to list // push to list
push(deferred); push(deferred);
@ -527,7 +527,7 @@ DeferredCancel &ChannelImpl::cancel(const std::string &tag)
BasicCancelFrame frame(_id, tag, false); BasicCancelFrame frame(_id, tag, false);
// send the frame, and create deferred object // send the frame, and create deferred object
auto *deferred = new DeferredCancel(this, send(frame)); auto *deferred = new DeferredCancel(this, !send(frame));
// push to list // push to list
push(deferred); push(deferred);