activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r777527 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
Date Fri, 22 May 2009 14:00:04 GMT
Author: gtully
Date: Fri May 22 14:00:04 2009
New Revision: 777527

URL: http://svn.apache.org/viewvc?rev=777527&view=rev
Log:
help with https://issues.apache.org/activemq/browse/AMQ-2262 when messages are discarded broker
side

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java?rev=777527&r1=777526&r2=777527&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
Fri May 22 14:00:04 2009
@@ -441,10 +441,8 @@
         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);



Mime
View raw message