diff --git a/db/repository.py b/db/repository.py
index 55942fe..6a33c3c 100644
--- a/db/repository.py
+++ b/db/repository.py
@@ -134,7 +134,7 @@ class Repository:
                     :STATUS,
                     :REJECT_CODE,                    
                     :BENF_ADDRS,
-                    :MSG_TYP
+                    :MSG_TYP,
                     :CREDITOR_AMT
                 )
             """
diff --git a/processors/data_mapper.py b/processors/data_mapper.py
index 62e987e..f206153 100644
--- a/processors/data_mapper.py
+++ b/processors/data_mapper.py
@@ -94,7 +94,7 @@ class RTGSDataMapper:
             amount_in = parsed_txn.get('amount', '0')
             txn_amt = cls.convert_amount(amount_in)
             txnind = "CR"
-            creditor_amt = parsed_txn.get('amount', '0')
+            creditor_amt = parsed_txn.get('creditor_amt', '0')
 
             # Date handling
             txn_date_raw = parsed_txn.get('tran_date', '') or ''