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));