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 2025/04/19 22:51:50 UTC
(camel) branch camel-4.8.x updated: CAMEL-21964: Fix bulk api 2.0 error deserialization
This is an automated email from the ASF dual-hosted git repository.
jeremyross pushed a commit to branch camel-4.8.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-4.8.x by this push:
new 501ab51c9d2 CAMEL-21964: Fix bulk api 2.0 error deserialization
501ab51c9d2 is described below
commit 501ab51c9d2ce34ec27c56a3e4c97f4d41e27b8b
Author: Jeremy Ross <je...@gmail.com>
AuthorDate: Sat Apr 19 17:15:30 2025 -0500
CAMEL-21964: Fix bulk api 2.0 error deserialization
---
.../component/salesforce/internal/client/DefaultBulkApiV2Client.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/DefaultBulkApiV2Client.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/DefaultBulkApiV2Client.java
index 09124872df8..3fcd74054bd 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/DefaultBulkApiV2Client.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/DefaultBulkApiV2Client.java
@@ -168,6 +168,7 @@ public class DefaultBulkApiV2Client extends AbstractClientBase implements BulkAp
public void onResponse(InputStream response, Map<String, String> responseHeaders, SalesforceException ex) {
if (ex != null) {
callback.onResponse(null, responseHeaders, ex);
+ return;
}
Jobs responseJobs = null;
try {
@@ -272,6 +273,7 @@ public class DefaultBulkApiV2Client extends AbstractClientBase implements BulkAp
public void onResponse(InputStream response, Map<String, String> responseHeaders, SalesforceException ex) {
if (ex != null) {
callback.onResponse(null, responseHeaders, ex);
+ return;
}
QueryJobs responseJobs = null;
try {
@@ -336,6 +338,7 @@ public class DefaultBulkApiV2Client extends AbstractClientBase implements BulkAp
public void onResponse(InputStream response, Map<String, String> responseHeaders, SalesforceException ex) {
if (ex != null) {
callback.onResponse(null, responseHeaders, ex);
+ return;
}
Job responseJob = null;
try {
@@ -355,6 +358,7 @@ public class DefaultBulkApiV2Client extends AbstractClientBase implements BulkAp
public void onResponse(InputStream response, Map<String, String> responseHeaders, SalesforceException ex) {
if (ex != null) {
callback.onResponse(null, responseHeaders, ex);
+ return;
}
QueryJob queryJob = null;
try {