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)