CAMEL-20297 camel-irc: do not swallow interrupted exceptions

apache · Jan 9, 2024 · f70676d · f70676d
1 parent 7689bc3
commit f70676d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcConsumer.java b/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcConsumer.java
@@ -66,7 +66,8 @@ protected void doStart() throws Exception {
         try {
             Thread.sleep(configuration.getCommandTimeout());
         } catch (InterruptedException ex) {
-            // ignore
+            LOG.info("Interrupted while sleeping before sending commands");
+            Thread.currentThread().interrupt();
         }
         if (ObjectHelper.isNotEmpty(configuration.getNickPassword())) {
             LOG.debug("Identifying and enforcing nick with NickServ.");

diff --git a/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcProducer.java b/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcProducer.java
@@ -99,7 +99,8 @@ protected void reconnect() {
         try {
             Thread.sleep(getEndpoint().getConfiguration().getCommandTimeout());
         } catch (InterruptedException ex) {
-            // ignore
+            LOG.info("Interrupted while sleeping before sending commands");
+            Thread.currentThread().interrupt();
         }
         getEndpoint().joinChannels();
     }