APEX-1122: adds LoB headers for user segmentation saga

Backbase · Jan 29, 2025 · 70a424b · 70a424b
1 parent a97fb57
commit 70a424b
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/.../audiences-core/src/main/java/com/backbase/stream/audiences/UserKindSegmentationSaga.java b/.../audiences-core/src/main/java/com/backbase/stream/audiences/UserKindSegmentationSaga.java
@@ -1,6 +1,8 @@
 package com.backbase.stream.audiences;
 
+import com.backbase.audiences.collector.api.service.ApiClient;
 import com.backbase.audiences.collector.api.service.v1.HandlersServiceApi;
+import com.backbase.buildingblocks.common.HttpCommunicationConstants;
 import com.backbase.stream.configuration.UserKindSegmentationProperties;
 import com.backbase.stream.worker.StreamTaskExecutor;
 import com.backbase.stream.worker.exception.StreamTaskException;
@@ -31,6 +33,12 @@ public UserKindSegmentationSaga(
     @Override
     public Mono<UserKindSegmentationTask> executeTask(UserKindSegmentationTask streamTask) {
         var request = streamTask.getCustomerOnboardedRequest();
+        ApiClient apiClient = handlersServiceApi.getApiClient();
+        if (request.getUserKind().getValue().equals("RetailCustomer")) {
+            apiClient.addDefaultHeader(HttpCommunicationConstants.LINE_OF_BUSINESS, "RETAIL");
+        } else if (request.getUserKind().getValue().equals("SME")) {
+            apiClient.addDefaultHeader(HttpCommunicationConstants.LINE_OF_BUSINESS, "BUSINESS");
+        }
 
         return handlersServiceApi.customerOnboarded(request)
             .then(Mono.fromCallable(() -> {