[hornetq-commits] JBoss hornetq SVN: r11941 - branches/one-offs/HornetQ_2_2_5_EAP_GA_JBPAPP_7710/src/main/org/hornetq/core/paging/cursor/impl.
Author: clebert.suconic(a)jboss.com
Date: 2011-12-23 10:40:21 -0500 (Fri, 23 Dec 2011)
New Revision: 11941
Modified:
branches/one-offs/HornetQ_2_2_5_EAP_GA_JBPAPP_7710/src/main/org/hornetq/core/paging/cursor/impl/PageSubscriptionCounterImpl.java
Log:
Backporting JBPAPP-7817
Modified:
branches/one-offs/HornetQ_2_2_5_EAP_GA_JBPAPP_7710/src/main/org/hornetq/core/paging/cursor/impl/PageSubscriptionCounterImpl.java
===================================================================
---
branches/one-offs/HornetQ_2_2_5_EAP_GA_JBPAPP_7710/src/main/org/hornetq/core/paging/cursor/impl/PageSubscriptionCounterImpl.java 2011-12-23
15:39:33 UTC (rev 11940)
+++
branches/one-offs/HornetQ_2_2_5_EAP_GA_JBPAPP_7710/src/main/org/hornetq/core/paging/cursor/impl/PageSubscriptionCounterImpl.java 2011-12-23
15:40:21 UTC (rev 11941)
@@ -181,17 +181,24 @@
synchronized (this)
{
long tx = storage.generateUniqueID();
+
+ boolean txUsed = false;
for (Long record : incrementRecords)
{
+ txUsed = true;
storage.deleteIncrementRecord(tx, record.longValue());
}
if (recordID >= 0)
{
+ txUsed = true;
storage.deletePageCounter(tx, this.recordID);
}
- storage.commit(tx);
+ if (txUsed)
+ {
+ storage.commit(tx);
+ }
}
}