diff options
| author | Robert Gemmell <robbie@apache.org> | 2010-04-21 11:31:18 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2010-04-21 11:31:18 +0000 |
| commit | 9b5e88811a4fae38ba84e755469352190a3a39de (patch) | |
| tree | e846f7785f43f10eff7767d23706bb6e16804fea /java | |
| parent | 8a379cf5ca273aafa1896c77a07c7c0078811437 (diff) | |
| download | qpid-python-9b5e88811a4fae38ba84e755469352190a3a39de.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/qpid@936259 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHostImpl.java | 12 |
1 files changed, 8 insertions, 4 deletions
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 |
