Added log of workcontacts in user-cdc

pagopa · Nov 12, 2024 · 2fe6b61 · 2fe6b61
1 parent e459653
commit 2fe6b61
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/apps/user-cdc/src/main/java/it/pagopa/selfcare/user/event/UserInstitutionCdcService.java b/apps/user-cdc/src/main/java/it/pagopa/selfcare/user/event/UserInstitutionCdcService.java
@@ -220,6 +220,7 @@ public void consumerToSendScUserEvent(ChangeStreamDocument<UserInstitution> docu
         log.info("Starting consumerToSendScUserEvent ... ");
 
         userRegistryApi.findByIdUsingGET(USERS_FIELD_LIST_WITHOUT_FISCAL_CODE, userInstitutionChanged.getUserId())
+                .onItem().invoke(resource -> log.info("workContacts for user {} : {}",userInstitutionChanged.getUserId(),resource.getWorkContacts()))
                 .onFailure(this::checkIfIsRetryableException)
                 .retry().withBackOff(Duration.ofSeconds(retryMinBackOff), Duration.ofSeconds(retryMaxBackOff)).atMost(maxRetry)
                 .onItem().transformToUni(userResource -> Multi.createFrom().iterable(UserUtils.groupingProductAndReturnMinStateProduct(userInstitutionChanged.getProducts()))