MODTLR-13 Use Kafka from Testcontainers

folio-org · Mar 11, 2024 · 122167f · 122167f
1 parent 5ed88fb
commit 122167f
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 7 deletions.
diff --git a/src/main/java/org/folio/listener/kafka/KafkaEventListener.java b/src/main/java/org/folio/listener/kafka/KafkaEventListener.java
@@ -16,7 +16,7 @@ public class KafkaEventListener {
   private final SystemUserScopedExecutionService systemUserScopedExecutionService;
 
   public KafkaEventListener(@Autowired KafkaEventHandler eventHandler,
-                            @Autowired SystemUserScopedExecutionService systemUserScopedExecutionService) {
+    @Autowired SystemUserScopedExecutionService systemUserScopedExecutionService) {
     this.eventHandler = eventHandler;
     this.systemUserScopedExecutionService = systemUserScopedExecutionService;
   }

diff --git a/src/main/java/org/folio/service/impl/CustomTenantService.java b/src/main/java/org/folio/service/impl/CustomTenantService.java
@@ -13,20 +13,18 @@
 @Log4j2
 @Service
 @Primary
-
 public class CustomTenantService extends TenantService {
   private final PrepareSystemUserService systemUserService;
 
   public CustomTenantService(JdbcTemplate jdbcTemplate, FolioExecutionContext context,
-                             FolioSpringLiquibase folioSpringLiquibase,
-                             PrepareSystemUserService systemUserService) {
+    FolioSpringLiquibase folioSpringLiquibase, PrepareSystemUserService systemUserService) {
     super(jdbcTemplate, context, folioSpringLiquibase);
     this.systemUserService = systemUserService;
   }
 
   @Override
   protected void afterTenantUpdate(TenantAttributes tenantAttributes) {
-    log.debug("afterTenantUpdate:: parameters tenantAttributes: {}", tenantAttributes);
-    //systemUserService.setupSystemUser();
+    log.debug("afterTenantUpdate:: parameters tenantAttributes: {}", () -> tenantAttributes);
+    systemUserService.setupSystemUser();
   }
 }
diff --git a/src/main/java/org/folio/service/impl/EcsTlrServiceImpl.java b/src/main/java/org/folio/service/impl/EcsTlrServiceImpl.java
@@ -145,7 +145,7 @@ public void updateRequestItem(UUID secondaryRequestId, UUID itemId) {
 
   private void updateItemIfChanged(EcsTlrEntity ecsTlr, UUID itemId) {
     if (!itemId.equals(ecsTlr.getItemId())) {
-      log.info("updateItemIfChanged:: updating ECS TLR {}, new itemId is {}", ecsTlr, itemId);
+      log.info("updateItemIfChanged: updating ECS TLR {}, new itemId is {}", ecsTlr, itemId);
       ecsTlr.setItemId(itemId);
       ecsTlrRepository.save(ecsTlr);
       log.info("updateItemIfChanged: ECS TLR {} with secondary request ID {} is updated",