Index: common/MessageProcessor.cpp
===================================================================
--- common/MessageProcessor.cpp	(revision 4dbac8711b9d477a88ecf800f8ffa34aa6a46677)
+++ common/MessageProcessor.cpp	(revision 855f1534e611e9a242abd6232b54a224305e3178)
@@ -54,4 +54,6 @@
 
       if (ackedMessages.find(msg->id) != ackedMessages.end()) {
+         cout << "Not a duplicate" << endl;
+
          ackedMessages[msg->id] = getCurrentMillis();
 
@@ -98,7 +100,8 @@
 
    while (it2 != ackedMessages.end()) {
-      if ((getCurrentMillis() - it2->second) > 500)
+      if ((getCurrentMillis() - it2->second) > 5000) {
          ackedMessages.erase(it2++);
-      else
+         cout << "Deleting ack record" << endl;
+      }else
          it2++;
    }