From a5696b5fda8d92acd0b63ae8539bf9e4f175f6b1 Mon Sep 17 00:00:00 2001
From: Gordon Sim <gsim@apache.org>
Date: Thu, 26 Apr 2012 19:16:44 +0000
Subject: QPID-3974: update statistics for dropped duplicate messages in
 replication exchange (patch from Pavel Moravec)

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1331037 13f79535-47bb-0310-9956-ffa450edef68
---
 qpid/cpp/src/qpid/replication/ReplicationExchange.cpp | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

(limited to 'qpid/cpp/src')

diff --git a/qpid/cpp/src/qpid/replication/ReplicationExchange.cpp b/qpid/cpp/src/qpid/replication/ReplicationExchange.cpp
index dce0d750a4..66f4f14d0c 100644
--- a/qpid/cpp/src/qpid/replication/ReplicationExchange.cpp
+++ b/qpid/cpp/src/qpid/replication/ReplicationExchange.cpp
@@ -60,7 +60,13 @@ void ReplicationExchange::route(Deliverable& msg)
     if (args) {
         int eventType = args->getAsInt(REPLICATION_EVENT_TYPE);
         if (eventType) {
-            if (isDuplicate(args)) return;
+            if (isDuplicate(args)) {
+                if (mgmtExchange != 0) {
+                    mgmtExchange->inc_msgDrops();
+                    mgmtExchange->inc_byteDrops(msg.contentSize());
+                }
+	        return;
+	    }
             switch (eventType) {
               case ENQUEUE:
                 handleEnqueueEvent(args, msg);
-- 
cgit v1.2.1