Repository: activemq-cpp Updated Branches: refs/heads/3.8.x 5dee6c54a -> 08baa709a
https://issues.apache.org/jira/browse/AMQCPP-549 Fix memory leak when delivering a pending ack async. Project: http://git-wip-us.apache.org/repos/asf/activemq-cpp/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-cpp/commit/08baa709 Tree: http://git-wip-us.apache.org/repos/asf/activemq-cpp/tree/08baa709 Diff: http://git-wip-us.apache.org/repos/asf/activemq-cpp/diff/08baa709 Branch: refs/heads/3.8.x Commit: 08baa709a896b9c130fa6fd1304107bd4398685f Parents: 5dee6c5 Author: Timothy Bish <[email protected]> Authored: Thu Aug 14 12:53:16 2014 -0400 Committer: Timothy Bish <[email protected]> Committed: Thu Aug 14 12:53:16 2014 -0400 ---------------------------------------------------------------------- .../src/main/activemq/core/kernels/ActiveMQConsumerKernel.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-cpp/blob/08baa709/activemq-cpp/src/main/activemq/core/kernels/ActiveMQConsumerKernel.cpp ---------------------------------------------------------------------- diff --git a/activemq-cpp/src/main/activemq/core/kernels/ActiveMQConsumerKernel.cpp b/activemq-cpp/src/main/activemq/core/kernels/ActiveMQConsumerKernel.cpp index 2fad1fa..ffde2f7 100644 --- a/activemq-cpp/src/main/activemq/core/kernels/ActiveMQConsumerKernel.cpp +++ b/activemq-cpp/src/main/activemq/core/kernels/ActiveMQConsumerKernel.cpp @@ -1253,8 +1253,8 @@ void ActiveMQConsumerKernel::deliverAcks() { this->internal->executor.reset(Executors::newSingleThreadExecutor()); } - this->internal->executor->submit( - new AsyncMessageAckTask(ack, this->session, this->internal), true); + Pointer< Future<bool> >( this->internal->executor->submit( + new AsyncMessageAckTask(ack, this->session, this->internal), true)); } else { this->internal->deliveringAcks.set(false); }
