File tree Expand file tree Collapse file tree
src/main/java/org/mifos/processor/bulk/zeebe Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -156,5 +156,6 @@ private ZeebeVariables() {}
156156 public static final String CURRENCY = "currency" ;
157157
158158 public static final String AUTHORIZATION_RESPONSE = "authorizationResponse" ;
159-
159+ public static final String PAYEE_PARTY_RESPONSE = "payeePartyResponse" ;
160+ public static final String PAYEE_DFSP_ID = "payeeDFSPID" ;
160161}
Original file line number Diff line number Diff line change 44import static org .mifos .processor .bulk .zeebe .ZeebeVariables .CHANNEL_REQUEST ;
55import static org .mifos .processor .bulk .zeebe .ZeebeVariables .ORIGIN_CHANNEL_REQUEST ;
66import static org .mifos .processor .bulk .zeebe .ZeebeVariables .PARTY_LOOKUP_FSP_ID ;
7+ import static org .mifos .processor .bulk .zeebe .ZeebeVariables .PAYEE_DFSP_ID ;
78import static org .mifos .processor .bulk .zeebe .worker .Worker .ACCOUNT_LOOKUP_CALLBACK ;
89
910import com .fasterxml .jackson .databind .ObjectMapper ;
@@ -42,6 +43,7 @@ public void setup() {
4243 Party payee = new Party (partyIdInfo );
4344 transactionChannelRequestDTO .setPayee (payee );
4445 existingVariables .put (CHANNEL_REQUEST , objectMapper .writeValueAsString (transactionChannelRequestDTO ));
46+ existingVariables .put (PAYEE_DFSP_ID , payeeFspId );
4547 client .newCompleteCommand (job .getKey ()).variables (existingVariables ).send ().join ();
4648 }).name (ACCOUNT_LOOKUP_CALLBACK .getValue ()).open ();
4749 }
You can’t perform that action at this time.
0 commit comments