Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

help with https://issues.apache.org/activemq/browse/AMQ-2262 when messages are discarded broker side 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@777527 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2009-05-22 14:00:04 +00:00
parent b997d257d5
commit 9b801d19d0
1 changed files with 0 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
View File

@ -441,10 +441,8 @@ public class TopicSubscription extends AbstractSubscription {
message.decrementReferenceCount(); message.decrementReferenceCount();
matched.remove(message); matched.remove(message);
discarded++; discarded++;
dequeueCounter.incrementAndGet();
if(destination != null) { if(destination != null) {
destination.getDestinationStatistics().getDequeues().increment(); destination.getDestinationStatistics().getDequeues().increment();
destination.getDestinationStatistics().getInflight().decrement();
} }
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("Discarding message " + message); LOG.debug("Discarding message " + message);