You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2014/10/23 18:00:16 UTC
git commit: https://issues.apache.org/jira/browse/AMQ-5266 track
cursor pending additions size in debug logging
Repository: activemq
Updated Branches:
refs/heads/trunk 3042797b4 -> 33089f3fb
https://issues.apache.org/jira/browse/AMQ-5266 track cursor pending additions size in debug logging
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/33089f3f
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/33089f3f
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/33089f3f
Branch: refs/heads/trunk
Commit: 33089f3fbba390e2cefccd4aa0d2f72c7ee82862
Parents: 3042797
Author: gtully <ga...@gmail.com>
Authored: Thu Oct 23 16:56:24 2014 +0100
Committer: gtully <ga...@gmail.com>
Committed: Thu Oct 23 16:56:24 2014 +0100
----------------------------------------------------------------------
.../src/main/java/org/apache/activemq/broker/region/Queue.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/33089f3f/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
----------------------------------------------------------------------
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
index 5778fed..a1b8b07 100755
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
@@ -944,8 +944,8 @@ public class Queue extends BaseDestination implements Task, UsageListener, Index
messagesLock.readLock().unlock();
}
return destination.getQualifiedName() + ", subscriptions=" + consumers.size()
- + ", memory=" + memoryUsage.getPercentUsage() + "%, size=" + size + ", in flight groups="
- + messageGroupOwners;
+ + ", memory=" + memoryUsage.getPercentUsage() + "%, size=" + size + ", pending="
+ + indexOrderedCursorUpdates.size();
}
@Override
@@ -1877,7 +1877,7 @@ public class Queue extends BaseDestination implements Task, UsageListener, Index
LOG.debug("{} toPageIn: {}, Inflight: {}, pagedInMessages.size {}, pagedInPendingDispatch.size {}, enqueueCount: {}, dequeueCount: {}, memUsage:{}",
new Object[]{
- destination.getPhysicalName(),
+ this,
toPageIn,
destinationStatistics.getInflight().getCount(),
pagedInMessages.size(),