activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject git commit: https://issues.apache.org/jira/browse/AMQCPP-549
Date Thu, 14 Aug 2014 16:53:57 GMT
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 <tabish121@gmail.com>
Authored: Thu Aug 14 12:53:16 2014 -0400
Committer: Timothy Bish <tabish121@gmail.com>
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);
             }


Mime
View raw message