[jboss-svn-commits] JBL Code SVN: r26619 - labs/jbossesb/trunk/product/services/jbossesb/src/main/java/org/jboss/internal/soa/esb/persistence/format/db.

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

Author: beve
Date: 2009-05-19 09:18:07 -0400 (Tue, 19 May 2009)
New Revision: 26619

Modified:
   labs/jbossesb/trunk/product/services/jbossesb/src/main/java/org/jboss/internal/soa/esb/persistence/format/db/DBMessageStoreImpl.java
Log:
Work for https://jira.jboss.org/jira/browse/JBESB-2535 "logging for DBMessageStoreImpl"


Modified: labs/jbossesb/trunk/product/services/jbossesb/src/main/java/org/jboss/internal/soa/esb/persistence/format/db/DBMessageStoreImpl.java
===================================================================
--- labs/jbossesb/trunk/product/services/jbossesb/src/main/java/org/jboss/internal/soa/esb/persistence/format/db/DBMessageStoreImpl.java	2009-05-19 13:11:50 UTC (rev 26618)
+++ labs/jbossesb/trunk/product/services/jbossesb/src/main/java/org/jboss/internal/soa/esb/persistence/format/db/DBMessageStoreImpl.java	2009-05-19 13:18:07 UTC (rev 26619)
@@ -374,7 +374,7 @@
         catch (final SQLException e)
         {
             if (logger.isDebugEnabled()) {
-                logger.debug("Deadlocks may occur under normal processing.");
+                logger.debug("dbms doesn't support setAutoCommit(false), deadlocks may occur under normal processing.");
                 logger.debug(e.getMessage(), e);
             }
         } 
@@ -403,17 +403,20 @@
                 } else {
                     //the message was not delivered
                     if (message.getProperties().getProperty(DELIVER_COUNT)==null) {
-                        //appearantly it was the first time
+                        //apparently it was the first time
                         message.getProperties().setProperty(RedeliverStore.DELIVER_COUNT, Integer.valueOf("1"));
+                        logger.debug("attempt 1 to redeliver " + uuid + " failed");
                         insert(uuid, message, MessageStore.CLASSIFICATION_RDLVR, "FALSE", con);
                     } else {
                         Integer redeliverCount = (Integer) message.getProperties().getProperty(DELIVER_COUNT);
                         if (redeliverCount < maxRedeliverCount || maxRedeliverCount < 0) {
                             //up the count
                             message.getProperties().setProperty(RedeliverStore.DELIVER_COUNT, ++redeliverCount);
+                            logger.debug("attempt " + redeliverCount + " to redeliver " + uuid + " failed");
                             insert(uuid, message, MessageStore.CLASSIFICATION_RDLVR, "FALSE", con);
                         } else {
                             //undeliverable, send to the DLQ
+                            logger.warn(" giving up and writing " + uuid + " to " + MessageStore.CLASSIFICATION_DLQ);
                             insert(uuid, message, MessageStore.CLASSIFICATION_DLQ, "FALSE", con);
                         }
                     }