summaryrefslogtreecommitdiff
path: root/java/broker
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2007-04-24 13:42:03 +0000
committerMartin Ritchie <ritchiem@apache.org>2007-04-24 13:42:03 +0000
commit89bed741ff9340801eba08d8d000203731be4e12 (patch)
treebf5105a28925033388b8373f57da377bf380b6ad /java/broker
parentb5aba49042cdbd29102d1b0f64cda13fd5a1efa5 (diff)
downloadqpid-python-89bed741ff9340801eba08d8d000203731be4e12.tar.gz
Reduced logging on requeue.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@531937 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker')
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java14
1 files changed, 5 insertions, 9 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java b/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
index 97c95dae5e..918b5fc176 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
@@ -431,24 +431,20 @@ public class AMQChannel
*/
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)