Author: clebert.suconic(a)jboss.com
Date: 2009-11-19 20:23:23 -0500 (Thu, 19 Nov 2009)
New Revision: 8328
Modified:
branches/ClebertTemporary/src/main/org/hornetq/core/management/impl/HornetQServerControlImpl.java
Log:
Fixing tests
Modified:
branches/ClebertTemporary/src/main/org/hornetq/core/management/impl/HornetQServerControlImpl.java
===================================================================
---
branches/ClebertTemporary/src/main/org/hornetq/core/management/impl/HornetQServerControlImpl.java 2009-11-20
01:17:02 UTC (rev 8327)
+++
branches/ClebertTemporary/src/main/org/hornetq/core/management/impl/HornetQServerControlImpl.java 2009-11-20
01:23:23 UTC (rev 8328)
@@ -438,6 +438,7 @@
{
Transaction transaction = resourceManager.removeTransaction(xid);
transaction.commit();
+ server.getStorageManager().completeOperations();
long recordID = server.getStorageManager().storeHeuristicCompletion(xid,
true);
resourceManager.putHeuristicCompletion(recordID, xid, true);
return true;
@@ -456,6 +457,7 @@
{
Transaction transaction = resourceManager.removeTransaction(xid);
transaction.rollback();
+ server.getStorageManager().completeOperations();
long recordID = server.getStorageManager().storeHeuristicCompletion(xid,
false);
resourceManager.putHeuristicCompletion(recordID, xid, false);
return true;