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/11/15 02:18:15 UTC

[camel] 01/02: camel-salesforce: Don't login if shutting down

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 706e77a49c57c3f5fda7de30c5a6ba0b636ff895
Author: Jeremy Ross <je...@gmail.com>
AuthorDate: Sun Nov 14 20:10:23 2021 -0600

    camel-salesforce: Don't login if shutting down
---
 .../component/salesforce/internal/streaming/SubscriptionHelper.java    | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java
index d730a66..c3831ba 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java
@@ -543,6 +543,9 @@ public class SubscriptionHelper extends ServiceSupport {
         try {
             for (;;) {
                 try {
+                    if (isStoppingOrStopped()) {
+                        return;
+                    }
                     session.login(session.getAccessToken());
                     break;
                 } catch (SalesforceException e) {