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

This commit is contained in:
Clebert Suconic 2021-01-06 10:27:01 -05:00
parent b1b88b4f6f a6160dac14
commit 168883df20
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java
View File

@ -654,7 +654,7 @@ public abstract class AbstractJournalStorageManager extends CriticalComponentImp
@Override @Override
public void commitBindings(final long txID) throws Exception { public void commitBindings(final long txID) throws Exception {
bindingsJournal.appendCommitRecord(txID, true); bindingsJournal.appendCommitRecord(txID, true, getContext(true), true);
} }
@Override @Override
@ -896,7 +896,7 @@ public abstract class AbstractJournalStorageManager extends CriticalComponentImp
public void storeID(final long journalID, final long id) throws Exception { public void storeID(final long journalID, final long id) throws Exception {
readLock(); readLock();
try { try {
bindingsJournal.appendAddRecord(journalID, JournalRecordIds.ID_COUNTER_RECORD, BatchingIDGenerator.createIDEncodingSupport(id), true); bindingsJournal.appendAddRecord(journalID, JournalRecordIds.ID_COUNTER_RECORD, BatchingIDGenerator.createIDEncodingSupport(id), true, getContext(true));
} finally { } finally {
readUnLock(); readUnLock();
} }