From a6160dac1428f28f8e168e05763f68259d1dbaa7 Mon Sep 17 00:00:00 2001 From: Clebert Suconic Date: Tue, 5 Jan 2021 15:17:20 -0500 Subject: [PATCH] ARTEMIS-3052 Not block on Binding operations There no need to test on this commit, since current tests are enough coverage on this change. --- .../impl/journal/AbstractJournalStorageManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java index 24c39f5a6f..9974b9a69b 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java @@ -654,7 +654,7 @@ public abstract class AbstractJournalStorageManager extends CriticalComponentImp @Override public void commitBindings(final long txID) throws Exception { - bindingsJournal.appendCommitRecord(txID, true); + bindingsJournal.appendCommitRecord(txID, true, getContext(true), true); } @Override @@ -896,7 +896,7 @@ public abstract class AbstractJournalStorageManager extends CriticalComponentImp public void storeID(final long journalID, final long id) throws Exception { readLock(); 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 { readUnLock(); }