(camel) branch camel-4.10.x updated: CAMEL-21964: Fix bulk api 2.0 error deserialization

[jeremyross]

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

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


The following commit(s) were added to refs/heads/camel-4.10.x by this push:
     new ab7b7cf79e3 CAMEL-21964: Fix bulk api 2.0 error deserialization
ab7b7cf79e3 is described below

commit ab7b7cf79e39d2b20b6b6b7b74c8e7c4b10a0a1d
Author: Jeremy Ross <jeremy.g.r...@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 {