diff options
| author | Keith Wall <kwall@apache.org> | 2012-03-13 09:31:30 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2012-03-13 09:31:30 +0000 |
| commit | f613e0e87478edaf5ac4723914181c16f23a8610 (patch) | |
| tree | 92411096cf62f5a5d457d185cca0791af4e4fee2 | |
| parent | ffd8e49658dbd2acd710e2e4b3a0dcaf3b97f11a (diff) | |
| download | qpid-python-f613e0e87478edaf5ac4723914181c16f23a8610.tar.gz | |
QPID-3868: Extra logging at DEBUG to better understand this failure
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1300021 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java index 30c2846732..cc1041d9de 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java @@ -2091,9 +2091,13 @@ public class SimpleAMQQueue implements AMQQueue, Subscription.StateListener, Mes // Only process nodes that are not currently deleted and not dequeued if (!node.isDispensed()) { - // If the node has exired then aquire it + // If the node has exired then acquire it if (node.expired() && node.acquire()) { + if (_logger.isDebugEnabled()) + { + _logger.debug("Dequeuing expired node " + node); + } // Then dequeue it. dequeueEntry(node); } |