(camel) 02/02: CAMEL-21740: added error handling for corrupt replay ids

[davsclaus]

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

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

commit 5990ad8a3f60bb44c88b3746d37fa4f250e8e2ee
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sun Feb 16 11:14:43 2025 +0100

    CAMEL-21740: added error handling for corrupt replay ids
---
 .../camel/component/salesforce/internal/client/PubSubApiClient.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/PubSubApiClient.java
 
b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/PubSubApiClient.java
index 8f7979fbf8c..f16e9ade9e3 100644
--- 
a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/PubSubApiClient.java
+++ 
b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/PubSubApiClient.java
@@ -73,7 +73,8 @@ public class PubSubApiClient extends ServiceSupport {
 
     public static final String PUBSUB_ERROR_AUTH_ERROR = 
"sfdc.platform.eventbus.grpc.service.auth.error";
     private static final String PUBSUB_ERROR_AUTH_REFRESH_INVALID = 
"sfdc.platform.eventbus.grpc.service.auth.refresh.invalid";
-    private static final String PUBSUB_ERROR_CORRUPTED_REPLAY_ID = 
"sfdc.platform.eventbus.grpc.subscription.fetch.replayid.corrupted";
+    private static final String PUBSUB_ERROR_CORRUPTED_REPLAY_ID
+            = 
"sfdc.platform.eventbus.grpc.subscription.fetch.replayid.corrupted";
 
     protected PubSubGrpc.PubSubStub asyncStub;
     protected PubSubGrpc.PubSubBlockingStub blockingStub;
@@ -346,7 +347,8 @@ public class PubSubApiClient extends ServiceSupport {
                             LOG.debug("logged in {}", consumer.getTopic());
                         }
                         case PUBSUB_ERROR_CORRUPTED_REPLAY_ID -> {
-                            LOG.error("replay id is corrupt. try resubscribing 
with LATEST replay preset");
+                            LOG.error("replay id: " + replayId
+                                      + " is corrupt. Trying to recover by 
resubscribing with LATEST replay preset");
                             replayId = null;
                             initialReplayPreset = ReplayPreset.LATEST;
                         }