You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ri...@apache.org on 2007/04/24 15:42:04 UTC

svn commit: r531937 - /incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java

Author: ritchiem
Date: Tue Apr 24 06:42:03 2007
New Revision: 531937

URL: http://svn.apache.org/viewvc?view=rev&rev=531937
Log:
Reduced logging on requeue.

Modified:
    incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java

Modified: incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java?view=diff&rev=531937&r1=531936&r2=531937
==============================================================================
--- incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java (original)
+++ incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java Tue Apr 24 06:42:03 2007
@@ -431,24 +431,20 @@
      */
     public void requeue() throws AMQException
     {
-        if (_log.isInfoEnabled())
-        {
-            _log.info("Requeuing for " + toString());
-        }
-
         // we must create a new map since all the messages will get a new delivery tag when they are redelivered
         Collection<UnacknowledgedMessage> messagesToBeDelivered = _unacknowledgedMessageMap.cancelAllMessages();
 
-        if (_log.isDebugEnabled())
-        {
-            _log.info("Requeuing " + messagesToBeDelivered.size() + " unacked messages.");
-        }
         // Deliver these messages out of the transaction as their delivery was never
         // part of the transaction only the receive.
         TransactionalContext deliveryContext = null;
 
         if (!messagesToBeDelivered.isEmpty())
         {
+            if (_log.isInfoEnabled())
+            {
+                _log.info("Requeuing " + messagesToBeDelivered.size() + " unacked messages. for " + toString());
+            }
+
             if (!(_txnContext instanceof NonTransactionalContext))
             {
 //                if (_nonTransactedContext == null)