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

https://issues.apache.org/jira/browse/AMQ-5266 track cursor pending additions size in debug logging

This commit is contained in:
gtully 2014-10-23 16:56:24 +01:00
parent 3042797b41
commit 33089f3fbb
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
View File

@ -944,8 +944,8 @@ public class Queue extends BaseDestination implements Task, UsageListener, Index
messagesLock.readLock().unlock(); messagesLock.readLock().unlock();
} }
return destination.getQualifiedName() + ", subscriptions=" + consumers.size() return destination.getQualifiedName() + ", subscriptions=" + consumers.size()
+ ", memory=" + memoryUsage.getPercentUsage() + "%, size=" + size + ", in flight groups=" + ", memory=" + memoryUsage.getPercentUsage() + "%, size=" + size + ", pending="
+ messageGroupOwners; + indexOrderedCursorUpdates.size();
} }
@Override @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:{}", LOG.debug("{} toPageIn: {}, Inflight: {}, pagedInMessages.size {}, pagedInPendingDispatch.size {}, enqueueCount: {}, dequeueCount: {}, memUsage:{}",
new Object[]{ new Object[]{
destination.getPhysicalName(), this,
toPageIn, toPageIn,
destinationStatistics.getInflight().getCount(), destinationStatistics.getInflight().getCount(),
pagedInMessages.size(), pagedInMessages.size(),