Repository: qpid-cpp Updated Branches: refs/heads/master 5272790a5 -> 47d89fe98
QPID-7376: don't expire messages if prefetch is 0; correction to previous commit Project: http://git-wip-us.apache.org/repos/asf/qpid-cpp/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-cpp/commit/47d89fe9 Tree: http://git-wip-us.apache.org/repos/asf/qpid-cpp/tree/47d89fe9 Diff: http://git-wip-us.apache.org/repos/asf/qpid-cpp/diff/47d89fe9 Branch: refs/heads/master Commit: 47d89fe985594d36c8f0f44a2dfe79f73cf31f30 Parents: 5272790 Author: Gordon Sim <[email protected]> Authored: Wed Aug 3 20:07:39 2016 +0100 Committer: Gordon Sim <[email protected]> Committed: Wed Aug 3 20:07:39 2016 +0100 ---------------------------------------------------------------------- src/qpid/client/amqp0_10/SessionImpl.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-cpp/blob/47d89fe9/src/qpid/client/amqp0_10/SessionImpl.cpp ---------------------------------------------------------------------- diff --git a/src/qpid/client/amqp0_10/SessionImpl.cpp b/src/qpid/client/amqp0_10/SessionImpl.cpp index b3bb9d0..4aa456a 100644 --- a/src/qpid/client/amqp0_10/SessionImpl.cpp +++ b/src/qpid/client/amqp0_10/SessionImpl.cpp @@ -332,7 +332,7 @@ struct IncomingMessageHandler : IncomingMessages::Handler bool expire(IncomingMessages::MessageTransfer& transfer) { - if (receiver && receiver->getName() == transfer.getDestination()/* && receiver->getCapacity() > 0*/) { + if (receiver && receiver->getName() == transfer.getDestination() && receiver->getCapacity() > 0) { receiver->received(); return true; } else { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
