[MODPUBSUB-158] Initialize headers map when registering subscribers d…

…uring module initialization
folio-org · Apr 7, 2021 · 2cef43d · 2cef43d
1 parent f3cb9b3
commit 2cef43d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/mod-pubsub-server/src/main/java/org/folio/services/impl/StartupServiceImpl.java b/mod-pubsub-server/src/main/java/org/folio/services/impl/StartupServiceImpl.java
@@ -13,6 +13,7 @@
 import org.springframework.stereotype.Component;
 
 import java.util.Collections;
+import java.util.HashMap;
 
 import static org.folio.rest.jaxrs.model.MessagingModule.ModuleRole.SUBSCRIBER;
 
@@ -45,6 +46,7 @@ public void initSubscribers() {
           OkapiConnectionParams params = new OkapiConnectionParams(vertx);
           params.setOkapiUrl(kafkaConfig.getOkapiUrl());
           params.setTenantId(messagingModule.getTenantId());
+          params.setHeaders(new HashMap<>());
           kafkaTopicService.createTopics(Collections.singletonList(messagingModule.getEventType()), messagingModule.getTenantId())
             .compose(ar -> consumerService.subscribe(Collections.singletonList(messagingModule.getEventType()), params));
         });