diff --git a/src/main/java/org/mifos/processor/bulk/zeebe/ZeebeVariables.java b/src/main/java/org/mifos/processor/bulk/zeebe/ZeebeVariables.java
index 8a1d3e94..93249187 100644
--- a/src/main/java/org/mifos/processor/bulk/zeebe/ZeebeVariables.java
+++ b/src/main/java/org/mifos/processor/bulk/zeebe/ZeebeVariables.java
@@ -156,5 +156,6 @@ private ZeebeVariables() {}
     public static final String CURRENCY = "currency";
 
     public static final String AUTHORIZATION_RESPONSE = "authorizationResponse";
-
+    public static final String PAYEE_PARTY_RESPONSE = "payeePartyResponse";
+    public static final String PAYEE_DFSP_ID = "payeeDFSPID";
 }
diff --git a/src/main/java/org/mifos/processor/bulk/zeebe/worker/AccountLookupCallbackWorker.java b/src/main/java/org/mifos/processor/bulk/zeebe/worker/AccountLookupCallbackWorker.java
index a424dc2f..1da26465 100644
--- a/src/main/java/org/mifos/processor/bulk/zeebe/worker/AccountLookupCallbackWorker.java
+++ b/src/main/java/org/mifos/processor/bulk/zeebe/worker/AccountLookupCallbackWorker.java
@@ -4,6 +4,7 @@
 import static org.mifos.processor.bulk.zeebe.ZeebeVariables.CHANNEL_REQUEST;
 import static org.mifos.processor.bulk.zeebe.ZeebeVariables.ORIGIN_CHANNEL_REQUEST;
 import static org.mifos.processor.bulk.zeebe.ZeebeVariables.PARTY_LOOKUP_FSP_ID;
+import static org.mifos.processor.bulk.zeebe.ZeebeVariables.PAYEE_DFSP_ID;
 import static org.mifos.processor.bulk.zeebe.worker.Worker.ACCOUNT_LOOKUP_CALLBACK;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
@@ -42,6 +43,7 @@ public void setup() {
             Party payee = new Party(partyIdInfo);
             transactionChannelRequestDTO.setPayee(payee);
             existingVariables.put(CHANNEL_REQUEST, objectMapper.writeValueAsString(transactionChannelRequestDTO));
+            existingVariables.put(PAYEE_DFSP_ID, payeeFspId);
             client.newCompleteCommand(job.getKey()).variables(existingVariables).send().join();
         }).name(ACCOUNT_LOOKUP_CALLBACK.getValue()).open();
     }