diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
index bfa3476075..8ef7d4dc6c 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
@@ -441,10 +441,8 @@ public class TopicSubscription extends AbstractSubscription {
         message.decrementReferenceCount();
         matched.remove(message);
         discarded++;
-        dequeueCounter.incrementAndGet();
         if(destination != null) {
             destination.getDestinationStatistics().getDequeues().increment();
-            destination.getDestinationStatistics().getInflight().decrement();
         }
         if (LOG.isDebugEnabled()) {
             LOG.debug("Discarding message " + message);