Publishing Payee DfspId (#70)

Author: apurbraj

src/main/java/org/mifos/processor/bulk/camel/processor/AccountLookupCallbackProcessor.java

@@ -39,6 +39,7 @@ public void process(Exchange exchange) throws Exception {
             variables.put(ACCOUNT_LOOKUP_FAILED, false);
             variables.put(PAYEE_PARTY_ID, accountLookupResponseDTO.getPaymentModalityList().get(0).getFinancialAddress());
             variables.put(PAYEE_PARTY_ID_TYPE, accountLookupResponseDTO.getPaymentModalityList().get(0).getPaymentModality());
+            variables.put(PARTY_LOOKUP_FSP_ID, accountLookupResponseDTO.getPaymentModalityList().get(0).getBankingInstitutionCode());
             exchange.setProperty(CACHED_TRANSACTION_ID, accountLookupResponseDTO.getRequestId());
         }catch(IOException e){
             variables.put(ACCOUNT_LOOKUP_FAILED, true);

src/main/java/org/mifos/processor/bulk/zeebe/ZeebeVariables.java

@@ -128,5 +128,6 @@ private ZeebeVariables() {
     public static final String FILE_VALIDITY = "isFileValid";
 
     public static final String NOTE = "note";
+    public static final String PARTY_LOOKUP_FSP_ID = "partyLookupFspId";
 
 }

src/main/java/org/mifos/processor/bulk/zeebe/worker/AccountLookupCallbackWorker.java

@@ -38,13 +38,14 @@ public void setup(){
                     PartyIdInfo partyIdInfo = new PartyIdInfo(transactionChannelRequestDTO.getPayee().getPartyIdInfo().getPartyIdType(), payeeId);
                     Party payee =new Party(partyIdInfo);
                     transactionChannelRequestDTO.setPayee(payee);
-                    existingVariables.put(CHANNEL_REQUEST, transactionChannelRequestDTO);
+                    existingVariables.put(CHANNEL_REQUEST, objectMapper.writeValueAsString(transactionChannelRequestDTO));
                     client.newCompleteCommand(job.getKey())
                             .variables(existingVariables)
                             .send()
+                            .join()
                     ;
                 })
-                .name(String.valueOf(ACCOUNT_LOOKUP_CALLBACK))
+                .name(ACCOUNT_LOOKUP_CALLBACK.getValue())
                 .open();
     }
 }