Add rawPayload option to Salesforce source connector (#1846)

* Add rawPayload option to Salesforce source connector Signed-off-by: Andrea Cosentino <ancosen@gmail.com> * Add rawPayload option to Salesforce source connector Signed-off-by: Andrea Cosentino <ancosen@gmail.com> --------- Signed-off-by: Andrea Cosentino <ancosen@gmail.com>
apache · Jan 23, 2024 · 44d23e5 · 44d23e5
1 parent 619c646
commit 44d23e5
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/kamelets/salesforce-source.kamelet.yaml b/kamelets/salesforce-source.kamelet.yaml
@@ -113,6 +113,11 @@ spec:
         description: The operation to use
         type: string
         default: subscribe
+      rawPayload:
+        title: Raw Payload
+        description: Use raw payload String for request and response (either JSON or XML depending on format), instead of DTOs, false by default.
+        type: boolean
+        default: false
   types:
     out:
       mediaType: application/json
@@ -140,6 +145,7 @@ spec:
         notifyForOperationDelete: "{{notifyForOperationDelete}}"
         notifyForOperationUndelete: "{{notifyForOperationUndelete}}"
         sObjectQuery: "{{query}}"
+        rawPayload: "{{rawPayload}}"
       steps:
       - marshal:
           json: {}

diff --git a/library/camel-kamelets/src/main/resources/kamelets/salesforce-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/salesforce-source.kamelet.yaml
@@ -113,6 +113,11 @@ spec:
         description: The operation to use
         type: string
         default: subscribe
+      rawPayload:
+        title: Raw Payload
+        description: Use raw payload String for request and response (either JSON or XML depending on format), instead of DTOs, false by default.
+        type: boolean
+        default: false
   types:
     out:
       mediaType: application/json
@@ -140,6 +145,7 @@ spec:
         notifyForOperationDelete: "{{notifyForOperationDelete}}"
         notifyForOperationUndelete: "{{notifyForOperationUndelete}}"
         sObjectQuery: "{{query}}"
+        rawPayload: "{{rawPayload}}"
       steps:
       - marshal:
           json: {}