From 70a424b110f144439bbb5618f137475872833d13 Mon Sep 17 00:00:00 2001 From: Mahdi Shabani Date: Wed, 29 Jan 2025 10:56:50 +0100 Subject: [PATCH] APEX-1122: adds LoB headers for user segmentation saga --- .../stream/audiences/UserKindSegmentationSaga.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/stream-audiences/audiences-core/src/main/java/com/backbase/stream/audiences/UserKindSegmentationSaga.java b/stream-audiences/audiences-core/src/main/java/com/backbase/stream/audiences/UserKindSegmentationSaga.java index 90e69af6b..db8b26215 100644 --- a/stream-audiences/audiences-core/src/main/java/com/backbase/stream/audiences/UserKindSegmentationSaga.java +++ b/stream-audiences/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 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(() -> {