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)
