(camel) branch main updated: Clean up smpp reconnect methods

[gnodet]

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

gnodet pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new b85d39ddb95 Clean up smpp reconnect methods
b85d39ddb95 is described below

commit b85d39ddb95d3760e939e89fb4dbd042914c6029
Author: Guillaume Nodet <gno...@gmail.com>
AuthorDate: Wed May 22 14:01:00 2024 +0200

    Clean up smpp reconnect methods
---
 .../main/java/org/apache/camel/component/smpp/SmppConsumer.java    | 7 ++++---
 .../main/java/org/apache/camel/component/smpp/SmppProducer.java    | 7 ++++---
 2 files changed, 8 insertions(+), 6 deletions(-)

diff --git 
a/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppConsumer.java
 
b/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppConsumer.java
index d2502aa163f..0184cba8b00 100644
--- 
a/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppConsumer.java
+++ 
b/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppConsumer.java
@@ -80,7 +80,7 @@ public class SmppConsumer extends DefaultConsumer {
                         ? "Session to {} was unbound - trying to reconnect" : 
"Lost connection to: {} - trying to reconnect...",
                         getEndpoint().getConnectionString());
                 closeSession();
-                reconnect(configuration.getInitialReconnectDelay());
+                reconnect();
             }
         };
         this.messageReceiverListener
@@ -185,9 +185,10 @@ public class SmppConsumer extends DefaultConsumer {
         }
     }
 
-    private void reconnect(final long initialReconnectDelay) {
+    private void reconnect() {
         if (reconnectLock.tryLock()) {
-            BlockingTask task = newReconnectTask(reconnectService, 
RECONNECT_TASK_NAME, initialReconnectDelay,
+            BlockingTask task = newReconnectTask(reconnectService, 
RECONNECT_TASK_NAME,
+                    configuration.getInitialReconnectDelay(),
                     configuration.getReconnectDelay(),
                     configuration.getMaxReconnect());
 
diff --git 
a/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppProducer.java
 
b/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppProducer.java
index b8841fad205..4e130ce783b 100644
--- 
a/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppProducer.java
+++ 
b/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppProducer.java
@@ -76,7 +76,7 @@ public class SmppProducer extends DefaultProducer {
                         ? "Session to {} was unbound - trying to reconnect" : 
"Lost connection to: {} - trying to reconnect...",
                         getEndpoint().getConnectionString());
                 closeSession();
-                reconnect(configuration.getInitialReconnectDelay());
+                reconnect();
             }
         };
     }
@@ -205,9 +205,10 @@ public class SmppProducer extends DefaultProducer {
         }
     }
 
-    private void reconnect(final long initialReconnectDelay) {
+    private void reconnect() {
         if (connectLock.tryLock()) {
-            BlockingTask task = newReconnectTask(reconnectService, 
RECONNECT_TASK_NAME, initialReconnectDelay,
+            BlockingTask task = newReconnectTask(reconnectService, 
RECONNECT_TASK_NAME,
+                    configuration.getInitialReconnectDelay(),
                     configuration.getReconnectDelay(), 
configuration.getMaxReconnect());
 
             try {