summaryrefslogtreecommitdiff
path: root/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
commit9b5e88811a4fae38ba84e755469352190a3a39de (patch)
treee846f7785f43f10eff7767d23706bb6e16804fea /java
parent8a379cf5ca273aafa1896c77a07c7c0078811437 (diff)
downloadqpid-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.java12
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