(camel) branch camel-4.8.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.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 <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 {