From e7eb4c714e2ca8d85b10b3ae1ec7f5cab31f601b Mon Sep 17 00:00:00 2001
From: Claudio Miranda <claudio@claudius.com.br>
Date: Fri, 14 Jun 2024 14:41:11 -0300
Subject: [PATCH] Fix salesforce-update-sink.kamelet (#341)

At runtime the bean is renamed which seems to cause the
NoSuchEndpointException: No endpoint could be found for: local-salesforce-1

CMLK-2211 Kamelet salesforce-update-sink throws NoSuchEndpointException
---
 salesforce-update-sink.kamelet.yaml | 19 +++++++++++++------
 1 file changed, 13 insertions(+), 6 deletions(-)

diff --git a/salesforce-update-sink.kamelet.yaml b/salesforce-update-sink.kamelet.yaml
index 3a901daa..ddfbf24e 100644
--- a/salesforce-update-sink.kamelet.yaml
+++ b/salesforce-update-sink.kamelet.yaml
@@ -87,14 +87,21 @@ spec:
     from:
       uri: kamelet:source
       steps:
-        - set-property:
+        - setHeader:
             name: sObjectId
-            jsonpath: "$['sObjectId']"
-        - set-property:
+            jsonpath: "$.sObjectId"
+        - setHeader:
             name: sObjectName
-            jsonpath: "$['sObjectName']"
+            jsonpath: "$.sObjectName"
         - transform:
-            jsonpath: "$['payload']"
+            jsonpath: "$.payload"
         - marshal:
             json: {}
-        - toD: "{{local-salesforce}}:updateSObject?sObjectId=${exchangeProperty.sObjectId}&sObjectName=${exchangeProperty.sObjectName}&rawPayload=true"
+        - to:
+            uri: "{{local-salesforce}}:updateSObject"
+            parameters:
+              rawPayload: "true"
+        - removeHeader:
+            name: sObjectId
+        - removeHeader:
+            name: sObjectName