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

help in diagnosis of https://issues.apache.org/activemq/browse/AMQ-2749 - provide log message when waiting for space to free up 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@948489 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2010-05-26 16:29:38 +00:00
parent 18adfefabe
commit ae7df9fcaa
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -107,12 +107,17 @@ public class TopicSubscription extends AbstractSubscription {
}
}
if (maximumPendingMessages != 0) {
boolean warnedAboutWait = false;
synchronized(matchedListMutex){
while (matched.isFull()){
if (getContext().getStopping().get()) {
LOG.warn("stopped waiting for space in pendingMessage cursor for: " + node.getMessageId());
LOG.warn(toString() + ": stopped waiting for space in pendingMessage cursor for: " + node.getMessageId());
enqueueCounter.decrementAndGet();
return;
}
if (!warnedAboutWait) {
LOG.info(toString() + ": Pending message cursor ["+ matched + "] is full, temp usage (" + + matched.getSystemUsage().getTempUsage().getPercentUsage() + "%) or memory usage (" + matched.getSystemUsage().getMemoryUsage().getPercentUsage() + "%) limit reached, blocking message add() pending the release of resources.");
warnedAboutWait = true;
}
matchedListMutex.wait(20);
}