Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #406

This commit is contained in:
Clebert Suconic 2016-02-25 15:14:47 -05:00
parent 8196b1ddf0 e64ecf5523
commit e202240ccc
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/FileWrapperJournal.java
View File

@ -41,6 +41,7 @@ import org.apache.activemq.artemis.core.journal.impl.dataformat.JournalCompleteR
import org.apache.activemq.artemis.core.journal.impl.dataformat.JournalDeleteRecord;
import org.apache.activemq.artemis.core.journal.impl.dataformat.JournalDeleteRecordTX;
import org.apache.activemq.artemis.core.journal.impl.dataformat.JournalInternalRecord;
import org.apache.activemq.artemis.core.journal.impl.dataformat.JournalRollbackRecordTX;
/**
* Journal used at a replicating backup server during the synchronization of data with the 'live'
@ -208,13 +209,18 @@ public final class FileWrapperJournal extends JournalBase {
return FileWrapperJournal.class.getName() + "(currentFile=[" + currentFile + "], hash=" + super.toString() + ")";
}
// UNSUPPORTED STUFF
@Override
public void appendRollbackRecord(long txID, boolean sync, IOCompletion callback) throws Exception {
throw new ActiveMQUnsupportedPacketException();
JournalInternalRecord rollbackRecord = new JournalRollbackRecordTX(txID);
AtomicInteger value = transactions.remove(Long.valueOf(txID));
if (value != null) {
rollbackRecord.setNumberOfRecords(value.get());
}
writeRecord(rollbackRecord, sync, callback);
}
// UNSUPPORTED STUFF
@Override
public JournalLoadInformation load(LoaderCallback reloadManager) throws Exception {
throw new ActiveMQUnsupportedPacketException();