From 9b5e88811a4fae38ba84e755469352190a3a39de Mon Sep 17 00:00:00 2001 From: Robert Gemmell Date: Wed, 21 Apr 2010 11:31:18 +0000 Subject: QPID-2479: Add info/debug level logging to allow tracking the virtualhost housekeeping process Applied patch from Sorin Suciu Merged from 0.5.x-dev r930288 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@936259 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/qpid/server/virtualhost/VirtualHostImpl.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) (limited to 'java') diff --git a/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java b/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java index b208872a5a..4ae1ea6e08 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java +++ b/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 -- cgit v1.2.1