Author: clebert.suconic(a)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); - } } } });