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

Fix Delete TX on JDBCJournalImpl 

The JDBC in memory Tx representation was using the Tx ID instead of the
Record ID which was causing deletes to fail.  Also the Store line up
should be set to true as default.
This commit is contained in:
Martyn Taylor 2016-02-01 11:00:23 +00:00 committed by Clebert Suconic
parent bff6f124d3
commit fcd981027a
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.
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) {
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
private IOCompletion ioCompletion = null;
private boolean storeLineUp = false;
private boolean storeLineUp = true;
private boolean sync = false;
// DB Fields for all records