activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r1058928 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java
Date Fri, 14 Jan 2011 10:30:39 GMT
Author: gtully
Date: Fri Jan 14 10:30:39 2011
New Revision: 1058928

URL: http://svn.apache.org/viewvc?rev=1058928&view=rev
Log:
add destination name to debug log message

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java?rev=1058928&r1=1058927&r2=1058928&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java
Fri Jan 14 10:30:39 2011
@@ -747,7 +747,7 @@ public class Queue extends BaseDestinati
 
     private void expireMessages() {
         if (LOG.isDebugEnabled()) {
-            LOG.debug("Expiring messages ..");
+            LOG.debug(getActiveMQDestination().getQualifiedName() + " expiring messages ..");
         }
 
         // just track the insertion count
@@ -771,6 +771,9 @@ public class Queue extends BaseDestinati
         };
         doBrowse(browsedMessages, this.getMaxExpirePageSize());
         asyncWakeup();
+        if (LOG.isDebugEnabled()) {
+            LOG.debug(getActiveMQDestination().getQualifiedName() + " expiring messages done.");
+        }
     }
 
     public void gc() {



Mime
View raw message