[rhmessaging-commits] rhmessaging commits: r4004 - store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb.

[rhmessaging-commits at lists.jboss.org]

Author: rgemmell
Date: 2010-06-02 11:36:13 -0400 (Wed, 02 Jun 2010)
New Revision: 4004

Modified:
   store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java
Log:
Add some additional debug logging


Modified: store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java
===================================================================
--- store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java	2010-06-02 14:22:52 UTC (rev 4003)
+++ store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java	2010-06-02 15:36:13 UTC (rev 4004)
@@ -1112,11 +1112,11 @@
 
         try
         {
-            _deliveryDb.put(tx, key, value);
             if (_log.isDebugEnabled())
             {
-                _log.debug("Enqueuing message " + messageId + " on queue " + name + "[Transaction" + tx + "]");
+                _log.debug("Enqueuing message " + messageId + " on queue " + name + " [Transaction" + tx + "]");
             }
+            _deliveryDb.put(tx, key, value);
         }
         catch (DatabaseException e)
         {
@@ -1190,10 +1190,13 @@
      */
     public void commitTran(StoreContext context) throws AMQException
     {
-        // _log.debug("public void commitTran(StoreContext context = " + context + "): called");
-
         com.sleepycat.je.Transaction tx = (com.sleepycat.je.Transaction) context.getPayload();
 
+        if (_log.isDebugEnabled())
+        {
+            _log.debug("public void commitTran(StoreContext context = " + context + "): called with [Transaction" + tx + "]");
+        }
+        
         if (tx == null)
         {
             throw new AMQException("Fatal internal error: transactional context is empty at commitTran");