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 <gary.tu...@gmail.com> Authored: Thu Oct 23 16:56:24 2014 +0100 Committer: gtully <gary.tu...@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(),