[activemq-artemis] branch master updated: ARTEMIS-3052 Not block on Binding operations

[clebertsuconic]

This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
     new a6160da  ARTEMIS-3052 Not block on Binding operations
     new 168883d  This closes #3399
a6160da is described below

commit a6160dac1428f28f8e168e05763f68259d1dbaa7
Author: Clebert Suconic <clebertsuco...@apache.org>
AuthorDate: Tue Jan 5 15:17:20 2021 -0500

    ARTEMIS-3052 Not block on Binding operations
    
    There no need to test on this commit,
    since current tests are enough coverage on this change.
---
 .../core/persistence/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 24c39f5..9974b9a 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();
       }