From da78ff097a9288788f2e42685f4963767413a5ab Mon Sep 17 00:00:00 2001
From: maverickstuder <maverick.studer@knecon.com>
Date: Wed, 3 Apr 2024 19:40:53 +0200
Subject: [PATCH] RED-8702: Explore document databases to store entityLog -
 attempt to fix liquibase race condition

---
 .../commons/liquibase/TenantMongoLiquibaseExecutor.java       | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/knecon/fforesight/mongo/database/commons/liquibase/TenantMongoLiquibaseExecutor.java b/src/main/java/com/knecon/fforesight/mongo/database/commons/liquibase/TenantMongoLiquibaseExecutor.java
index c14a1e1..a46559d 100644
--- a/src/main/java/com/knecon/fforesight/mongo/database/commons/liquibase/TenantMongoLiquibaseExecutor.java
+++ b/src/main/java/com/knecon/fforesight/mongo/database/commons/liquibase/TenantMongoLiquibaseExecutor.java
@@ -16,6 +16,8 @@ import com.knecon.fforesight.tenantcommons.model.TenantResponse;
 import feign.RetryableException;
 import liquibase.Contexts;
 import liquibase.Liquibase;
+import liquibase.Scope;
+import liquibase.ThreadLocalScopeManager;
 import liquibase.changelog.ChangeSet;
 import liquibase.database.DatabaseFactory;
 import liquibase.ext.mongodb.database.MongoLiquibaseDatabase;
@@ -65,7 +67,7 @@ public class TenantMongoLiquibaseExecutor implements InitializingBean, ResourceL
         log.info("Initializing MongoDB liquibase for tenant {} / {}", tenant.getTenantId(), mongoUrl);
 
         try (SpringResourceAccessor resourceAccessor = new SpringResourceAccessor(resourceLoader)) {
-
+            Scope.setScopeManager(new ThreadLocalScopeManager());
             try (MongoLiquibaseDatabase database = (MongoLiquibaseDatabase) DatabaseFactory.getInstance()
                     .openDatabase(mongoUrl, mongoDBConnection.getUsername(), encryptionService.decrypt(mongoDBConnection.getPassword()), null, resourceAccessor)) {
                 database.setSupportsValidator(false);