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

Applied patch for https://issues.apache.org/activemq/browse/AMQ-1838 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@690645 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-08-31 06:51:27 +00:00
parent c2f71284ba
commit ec3d9adae5
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java
View File

@ -218,6 +218,13 @@ public abstract class PrefetchSubscription extends AbstractSubscription {
.getDestinationStatistics() .getDestinationStatistics()
.getDequeues() .getDequeues()
.increment(); .increment();
node
.getRegionDestination()
.getDestinationStatistics()
.getInflight()
.decrement();
prefetchExtension--; prefetchExtension--;
} }
} }
@ -354,6 +361,10 @@ public abstract class PrefetchSubscription extends AbstractSubscription {
sendToDLQ(context, node); sendToDLQ(context, node);
node.getRegionDestination().getDestinationStatistics() node.getRegionDestination().getDestinationStatistics()
.getDequeues().increment(); .getDequeues().increment();
node.getRegionDestination().getDestinationStatistics()
.getInflight().increment();
removeList.add(node); removeList.add(node);
dequeueCounter++; dequeueCounter++;
index++; index++;