summaryrefslogtreecommitdiff
path: root/qpid/java
diff options
context:
space:
mode:
authorRobert Gemmell <robbie@apache.org>2010-04-21 11:31:18 +0000
committerRobert Gemmell <robbie@apache.org>2010-04-21 11:31:18 +0000
commit408fdc7478b1cc24014f86fa0a7af930764bbd80 (patch)
treec3b75f4c06f0bf5aedc693913fc73c864f8e532d /qpid/java
parente5ad5c090ff0b2a7b226f41ef38dac575c3f7550 (diff)
downloadqpid-python-408fdc7478b1cc24014f86fa0a7af930764bbd80.tar.gz
QPID-2479: Add info/debug level logging to allow tracking the virtualhost housekeeping process
Applied patch from Sorin Suciu <ssuciu@gmail.com> Merged from 0.5.x-dev r930288 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@936259 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
-rw-r--r--qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java12
1 files changed, 8 insertions, 4 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java
index b208872a5a..4ae1ea6e08 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java
@@ -286,28 +286,32 @@ public class VirtualHostImpl implements Accessable, VirtualHost
/* add a timer task to iterate over queues, cleaning expired messages from queues with no consumers */
if (period != 0L)
{
- class RemoveExpiredMessagesTask extends TimerTask
+ class HouseKeepingTask extends TimerTask
{
+ Logger _hkLogger = Logger.getLogger(HouseKeepingTask.class);
+
public void run()
{
+ _hkLogger.info("Starting the houseKeeping job");
for (AMQQueue q : _queueRegistry.getQueues())
{
-
+ _hkLogger.debug("Checking message status for queue: "+q.getName().toString());
try
{
q.checkMessageStatus();
}
catch (Exception e)
{
- _logger.error("Exception in housekeeping for queue: " + q.getNameShortString().toString(), e);
+ _hkLogger.error("Exception in housekeeping for queue: " + q.getNameShortString().toString(), e);
//Don't throw exceptions as this will stop the
// house keeping task from running.
}
}
+ _hkLogger.info("HouseKeeping job completed.");
}
}
- final TimerTask expiredMessagesTask = new RemoveExpiredMessagesTask();
+ final TimerTask expiredMessagesTask = new HouseKeepingTask();
scheduleTask(period, expiredMessagesTask);
class ForceChannelClosuresTask extends TimerTask