From b574c985db2f749ac3d25db5bd5d8171269ef7e2 Mon Sep 17 00:00:00 2001
From: "CHIEFSOFT\\ameye" <ameye@chiefsfot.com>
Date: Tue, 17 Jun 2025 07:18:11 -0400
Subject: [PATCH] collect_loan_user_initiated

---
 app/integrations/kafka.py     | 2 +-
 app/integrations/simbrella.py | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/app/integrations/kafka.py b/app/integrations/kafka.py
index 23b333c..a30a01e 100644
--- a/app/integrations/kafka.py
+++ b/app/integrations/kafka.py
@@ -146,7 +146,7 @@ class KafkaIntegration:
         logger.info(f"Calling collect_loan service with message: {message}")
 
         try:
-            response = SimbrellaClient.collect_loan(message)
+            response = SimbrellaClient.collect_loan_user_initiated(message)
             logger.info(
                 f"Successfully sent message to collect_loan service: {response}"
             )
diff --git a/app/integrations/simbrella.py b/app/integrations/simbrella.py
index 84c34b7..b4cbd36 100644
--- a/app/integrations/simbrella.py
+++ b/app/integrations/simbrella.py
@@ -180,6 +180,7 @@ class SimbrellaClient:
     @staticmethod
     def collect_loan_user_initiated(data):
         # InitiatedBy = USER_INITIATED
+        logger.info(f"Calling CollectLoan collect_loan_user_initiated ******* endpoint with data: {data}")
         return SimbrellaClient._collect_loan(data)
 
     @staticmethod