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

The defered parameter indicatates if it failed, while the call in Tagger:close asumed that the parameter indicated usable. This is now fixed.

This commit is contained in:
aljar 2021-01-14 09:16:35 +01:00
parent f9d85f5d01
commit 3b7ebb1077
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/tagger.cpp
View File

@ -158,7 +158,7 @@ Deferred &Tagger::close()
if (_close) return *_close;
// create the deferred
_close = std::make_shared<Deferred>(_implementation->usable());
_close = std::make_shared<Deferred>(!_implementation->usable());
// if there are open messages or there is a queue, they will still get acked and we will then forward it
if (unacknowledged()) return *_close;