[hornetq-commits] JBoss hornetq SVN: r8306 - branches/ClebertTemporary/src/main/org/hornetq/core/transaction/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-11-17 23:38:26 -0500 (Tue, 17 Nov 2009)
New Revision: 8306

Modified:
   branches/ClebertTemporary/src/main/org/hornetq/core/transaction/impl/TransactionImpl.java
Log:
tweaks

Modified: branches/ClebertTemporary/src/main/org/hornetq/core/transaction/impl/TransactionImpl.java
===================================================================
--- branches/ClebertTemporary/src/main/org/hornetq/core/transaction/impl/TransactionImpl.java	2009-11-18 04:31:45 UTC (rev 8305)
+++ branches/ClebertTemporary/src/main/org/hornetq/core/transaction/impl/TransactionImpl.java	2009-11-18 04:38:26 UTC (rev 8306)
@@ -222,26 +222,29 @@
          // to execute this runnable in the correct order
          storageManager.afterCompleteOperations(new IOCompletion()
          {
-            
+
             public void onError(int errorCode, String errorMessage)
             {
                log.warn("IO Error completing the transaction, code = " + errorCode + ", message = " + errorMessage);
             }
-            
+
             public void done()
             {
-               for (TransactionOperation operation : operations)
+               if (operations != null)
                {
-                  try
+                  for (TransactionOperation operation : operations)
                   {
-                     operation.afterCommit(TransactionImpl.this);
+                     try
+                     {
+                        operation.afterCommit(TransactionImpl.this);
+                     }
+                     catch (Exception e)
+                     {
+                        // https://jira.jboss.org/jira/browse/HORNETQ-188
+                        // After commit shouldn't throw an exception
+                        log.warn(e.getMessage(), e);
+                     }
                   }
-                  catch (Exception e)
-                  {
-                     // https://jira.jboss.org/jira/browse/HORNETQ-188
-                     // After commit shouldn't throw an exception
-                     log.warn(e.getMessage(), e);
-                  }
                }
             }
          });