You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2010/04/02 16:53:28 UTC
svn commit: r930288 -
/qpid/branches/0.5.x-dev/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java
Author: robbie
Date: Fri Apr 2 14:53:28 2010
New Revision: 930288
URL: http://svn.apache.org/viewvc?rev=930288&view=rev
Log:
QPID-2479: Add info/debug level logging to allow tracking the virtualhost housekeeping process
Applied patch from Sorin Suciu <ss...@gmail.com>
Modified:
qpid/branches/0.5.x-dev/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java
Modified: qpid/branches/0.5.x-dev/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java
URL: http://svn.apache.org/viewvc/qpid/branches/0.5.x-dev/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java?rev=930288&r1=930287&r2=930288&view=diff
==============================================================================
--- qpid/branches/0.5.x-dev/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java (original)
+++ qpid/branches/0.5.x-dev/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java Fri Apr 2 14:53:28 2010
@@ -232,28 +232,32 @@ public class VirtualHost implements Acce
/* 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.getName().toString(), e);
+ _hkLogger.error("Exception in housekeeping for queue: " + q.getName().toString(), e);
//Don't throw exceptions as this will stop the
// house keeping task from running.
}
}
+ _hkLogger.info("HouseKeeping job completed.");
}
}
- _houseKeepingTimer.scheduleAtFixedRate(new RemoveExpiredMessagesTask(),
+ _houseKeepingTimer.scheduleAtFixedRate(new HouseKeepingTask(),
period / 2,
period);
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org