commit 4883523f77f3a0dc2847ca63feb56c949ccd0d65
author Timothy Bish <tabish121@gmail.com> Tue Jul 08 17:00:30 2014 -0400
committer Timothy Bish <tabish121@gmail.com> Tue Jul 08 17:00:30 2014 -0400
tree 7fb528cab62c9449c7c364bb7c0f22d7be67c530
parent cea38b8469591773d174fb80689439d1b39f70be

https://issues.apache.org/jira/browse/AMQCPP-546

Make the method in this class thread safe

activemq-cpp/src/main/activemq/core/ConnectionAudit.cpp

diff --git a/activemq-cpp/src/main/activemq/core/ConnectionAudit.cpp b/activemq-cpp/src/main/activemq/core/ConnectionAudit.cpp
index b8e3c5e..40b8cde 100644
--- a/activemq-cpp/src/main/activemq/core/ConnectionAudit.cpp
+++ b/activemq-cpp/src/main/activemq/core/ConnectionAudit.cpp
@@ -90,30 +90,31 @@
 
 ////////////////////////////////////////////////////////////////////////////////
 bool ConnectionAudit::isDuplicate(Dispatcher* dispatcher, Pointer<commands::Message> message) {
-
-    if (checkForDuplicates && message != NULL) {
-        Pointer<ActiveMQDestination> destination = message->getDestination();
-        if (destination != NULL) {
-            if (destination->isQueue()) {
+    synchronized(&this->impl->mutex) {
+        if (checkForDuplicates && message != NULL) {
+            Pointer<ActiveMQDestination> destination = message->getDestination();
+            if (destination != NULL) {
+                if (destination->isQueue()) {
+                    Pointer<ActiveMQMessageAudit> audit;
+                    try {
+                        audit = this->impl->destinations.get(destination);
+                    } catch (NoSuchElementException& ex) {
+                        audit.reset(new ActiveMQMessageAudit(auditDepth, auditMaximumProducerNumber));
+                        this->impl->destinations.put(destination, audit);
+                    }
+                    bool result = audit->isDuplicate(message->getMessageId());
+                    return result;
+                }
                 Pointer<ActiveMQMessageAudit> audit;
                 try {
-                    audit = this->impl->destinations.get(destination);
+                    audit = this->impl->dispatchers.get(dispatcher);
                 } catch (NoSuchElementException& ex) {
                     audit.reset(new ActiveMQMessageAudit(auditDepth, auditMaximumProducerNumber));
-                    this->impl->destinations.put(destination, audit);
+                    this->impl->dispatchers.put(dispatcher, audit);
                 }
                 bool result = audit->isDuplicate(message->getMessageId());
                 return result;
             }
-            Pointer<ActiveMQMessageAudit> audit;
-            try {
-                audit = this->impl->dispatchers.get(dispatcher);
-            } catch (NoSuchElementException& ex) {
-                audit.reset(new ActiveMQMessageAudit(auditDepth, auditMaximumProducerNumber));
-                this->impl->dispatchers.put(dispatcher, audit);
-            }
-            bool result = audit->isDuplicate(message->getMessageId());
-            return result;
         }
     }
     return false;
@@ -121,19 +122,21 @@
 
 ////////////////////////////////////////////////////////////////////////////////
 void ConnectionAudit::rollbackDuplicate(Dispatcher* dispatcher, Pointer<commands::Message> message) {
-    if (checkForDuplicates && message != NULL) {
-        Pointer<ActiveMQDestination> destination = message->getDestination();
-        if (destination != NULL) {
-            if (destination->isQueue()) {
-                try {
-                    Pointer<ActiveMQMessageAudit> audit = this->impl->destinations.get(destination);
-                    audit->rollback(message->getMessageId());
-                } catch (NoSuchElementException& ex) {}
-            } else {
-                try {
-                    Pointer<ActiveMQMessageAudit> audit = this->impl->dispatchers.get(dispatcher);
-                    audit->rollback(message->getMessageId());
-                } catch (NoSuchElementException& ex) {}
+    synchronized(&this->impl->mutex) {
+        if (checkForDuplicates && message != NULL) {
+            Pointer<ActiveMQDestination> destination = message->getDestination();
+            if (destination != NULL) {
+                if (destination->isQueue()) {
+                    try {
+                        Pointer<ActiveMQMessageAudit> audit = this->impl->destinations.get(destination);
+                        audit->rollback(message->getMessageId());
+                    } catch (NoSuchElementException& ex) {}
+                } else {
+                    try {
+                        Pointer<ActiveMQMessageAudit> audit = this->impl->dispatchers.get(dispatcher);
+                        audit->rollback(message->getMessageId());
+                    } catch (NoSuchElementException& ex) {}
+                }
             }
         }
     }