[jboss-cvs] JBoss Messaging SVN: r4267 - trunk/src/main/org/jboss/messaging/core/server/impl.

[jboss-cvs-commits at lists.jboss.org]

Author: jmesnil
Date: 2008-05-21 09:58:05 -0400 (Wed, 21 May 2008)
New Revision: 4267

Modified:
   trunk/src/main/org/jboss/messaging/core/server/impl/QueueImpl.java
Log:
added warning when a consumer is removed if it throws an exception when handling a message

Modified: trunk/src/main/org/jboss/messaging/core/server/impl/QueueImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/server/impl/QueueImpl.java	2008-05-21 13:32:11 UTC (rev 4266)
+++ trunk/src/main/org/jboss/messaging/core/server/impl/QueueImpl.java	2008-05-21 13:58:05 UTC (rev 4267)
@@ -632,6 +632,9 @@
          }
          catch (Throwable t)
          {
+            log.warn("removing consumer which did not handle a message, " +
+                  "consumer=" + consumer + ", message=" + reference, t);
+
             // If the consumer throws an exception we remove the consumer
             removeConsumer(consumer);