You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by je...@apache.org on 2021/12/05 22:21:29 UTC

[camel] 01/02: camel-salesforce: Fix allOrNone option

This is an automated email from the ASF dual-hosted git repository.

jeremyross pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 2df724d5b357da7118e4b0c14b7c0da899089ced
Author: Jeremy Ross <je...@gmail.com>
AuthorDate: Sun Dec 5 16:15:38 2021 -0600

    camel-salesforce: Fix allOrNone option
    
    It shouldn't come from message body.
---
 .../internal/processor/CompositeSObjectCollectionsProcessor.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/processor/CompositeSObjectCollectionsProcessor.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/processor/CompositeSObjectCollectionsProcessor.java
index 276007a..98319a7 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/processor/CompositeSObjectCollectionsProcessor.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/processor/CompositeSObjectCollectionsProcessor.java
@@ -144,7 +144,7 @@ public class CompositeSObjectCollectionsProcessor extends AbstractSalesforceProc
             throws SalesforceException {
         List<String> ids = getListParameter(SalesforceEndpointConfig.SOBJECT_IDS, exchange, USE_BODY, NOT_OPTIONAL);
         boolean allOrNone = Boolean.parseBoolean(
-                getParameter(SalesforceEndpointConfig.ALL_OR_NONE, exchange, USE_BODY, IS_OPTIONAL));
+                getParameter(SalesforceEndpointConfig.ALL_OR_NONE, exchange, IGNORE_BODY, IS_OPTIONAL));
         compositeClient.submitDeleteCompositeCollections(ids, allOrNone, determineHeaders(exchange),
                 (response, responseHeaders, exception) -> processResponse(exchange, response,
                         responseHeaders, exception, callback));