Author: borges
Date: 2011-11-30 11:33:09 -0500 (Wed, 30 Nov 2011)
New Revision: 11799
Modified:
trunk/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/FileWrapperJournal.java
Log:
HORNETQ-720 FIX: Replicated transactional deletes did no reference counting.
Modified:
trunk/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/FileWrapperJournal.java
===================================================================
---
trunk/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/FileWrapperJournal.java 2011-11-30
16:32:53 UTC (rev 11798)
+++
trunk/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/FileWrapperJournal.java 2011-11-30
16:33:09 UTC (rev 11799)
@@ -123,6 +123,7 @@
@Override
public void appendDeleteRecordTransactional(long txID, long id, EncodingSupport
record) throws Exception
{
+ count(txID);
JournalInternalRecord deleteRecordTX = new JournalDeleteRecordTX(txID, id,
record);
writeRecord(deleteRecordTX, false, null);
}
Show replies by date