PHEE-218 payee-commit-transfer worker fixed (#22)

openMF · Mar 10, 2023 · d2441ab · d2441ab
1 parent 3fe6ad8
commit d2441ab
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/main/java/org/mifos/connector/ams/zeebe/ZeebeeWorkers.java b/src/main/java/org/mifos/connector/ams/zeebe/ZeebeeWorkers.java
@@ -315,6 +315,11 @@ public void setupWorkers() {
                                 exchange.setProperty(TRANSFER_ACTION, CREATE.name());
                                 exchange.setProperty(ZEEBE_JOB_KEY, job.getKey());
 
+                                // setting party related variables as exchange property
+                                QuoteSwitchRequestDTO quoteRequest = objectMapper.readValue((String) variables.get(QUOTE_SWITCH_REQUEST), QuoteSwitchRequestDTO.class);
+                                exchange.setProperty(PARTY_ID, quoteRequest.getPayee().getPartyIdInfo().getPartyIdentifier());
+                                exchange.setProperty(PARTY_ID_TYPE, quoteRequest.getPayee().getPartyIdInfo().getPartyIdType());
+
                                 FspMoneyData amountData = zeebeVariable(exchange, "amount", FspMoneyData.class);
                                 MoneyData amount = new MoneyData(amountData.getAmount(), amountData.getCurrency());