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 #364

This commit is contained in:
Clebert Suconic 2016-02-01 10:11:35 -05:00
parent bff6f124d3 fcd981027a
commit cd04b49f89
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/JDBCJournalImpl.java
View File

@ -301,7 +301,7 @@ public class JDBCJournalImpl implements Journal {
// We actually only need the record ID in this instance. // We actually only need the record ID in this instance.
if (record.isTransactional()) { if (record.isTransactional()) {
RecordInfo info = new RecordInfo(record.getTxId(), record.getRecordType(), new byte[0], record.isUpdate(), record.getCompactCount()); RecordInfo info = new RecordInfo(record.getId(), record.getRecordType(), new byte[0], record.isUpdate(), record.getCompactCount());
if (record.getRecordType() == JDBCJournalRecord.DELETE_RECORD_TX) { if (record.getRecordType() == JDBCJournalRecord.DELETE_RECORD_TX) {
txHolder.recordsToDelete.add(info); txHolder.recordsToDelete.add(info);
} }

2
artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/JDBCJournalRecord.java
View File

@ -63,7 +63,7 @@ public class JDBCJournalRecord {
// Callback and sync operations // Callback and sync operations
private IOCompletion ioCompletion = null; private IOCompletion ioCompletion = null;
private boolean storeLineUp = false; private boolean storeLineUp = true;
private boolean sync = false; private boolean sync = false;
// DB Fields for all records // DB Fields for all records