Repository: activemq-cpp Updated Branches: refs/heads/trunk 7b7538ad2 -> 6b9bd99a1
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/6b9bd99a Tree: http://git-wip-us.apache.org/repos/asf/activemq-cpp/tree/6b9bd99a Diff: http://git-wip-us.apache.org/repos/asf/activemq-cpp/diff/6b9bd99a Branch: refs/heads/trunk Commit: 6b9bd99a1042d03690422d18d8bb94d1a2d3ed18 Parents: 7b7538a 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:50 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/6b9bd99a/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 6dd61b1..f0fc4cc 100644 --- a/activemq-cpp/src/main/activemq/core/kernels/ActiveMQConsumerKernel.cpp +++ b/activemq-cpp/src/main/activemq/core/kernels/ActiveMQConsumerKernel.cpp @@ -1254,8 +1254,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); }
