CAMEL-20297: do not swallow interrupted exceptions

components/camel-as2/camel-as2-api/src/main/java/org/apache/camel/component/as2/api/AS2ClientManager.java

@@ -392,7 +392,10 @@ public HttpCoreContext send(
             EntityParser.parseAS2MessageEntity(response);
         } catch (IOException e) {
             throw new HttpException("Failed to send http request message", e);
-        } catch (ExecutionException | InterruptedException ex) {
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+            throw new HttpException("Interrupted while sending the http request", e);
+        } catch (ExecutionException ex) {
             throw new HttpException("Retrieving connection from Pool failed or timed out", ex);
         }
         httpContext.setAttribute(HTTP_RESPONSE, response);

components/camel-controlbus/src/main/java/org/apache/camel/component/controlbus/ControlBusProducer.java

@@ -191,7 +191,8 @@ public void run() {
                             LOG.debug("Sleeping {} ms before starting route: {}", delay, id);
                             Thread.sleep(delay);
                         } catch (InterruptedException e) {
-                            // ignore
+                            LOG.info("Interrupted while waiting before starting the route");
+                            Thread.currentThread().interrupt();
                         }
                     }
                     getEndpoint().getCamelContext().getRouteController().startRoute(id);

components/camel-direct/src/main/java/org/apache/camel/component/direct/DirectProducer.java

@@ -96,6 +96,13 @@ public boolean process(Exchange exchange, AsyncCallback callback) {
                     return consumer.getAsyncProcessor().process(exchange, callback);
                 }
             }
+        } catch (InterruptedException e) {
+            LOG.info("Interrupted while processing the exchange");
+            Thread.currentThread().interrupt();
+
+            exchange.setException(e);
+            callback.done(true);
+            return true;
         } catch (Exception e) {
             exchange.setException(e);
             callback.done(true);

components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorProducer.java

@@ -100,7 +100,8 @@ public boolean process(final Exchange exchange, final AsyncCallback callback) {
                 try {
                     done = latch.await(timeout, TimeUnit.MILLISECONDS);
                 } catch (InterruptedException e) {
-                    // ignore
+                    LOG.info("Interrupted while waiting for the task to complete");
+                    Thread.currentThread().interrupt();
                 }
                 if (!done) {
                     // Remove timed out Exchange from disruptor endpoint.
@@ -127,7 +128,8 @@ public boolean process(final Exchange exchange, final AsyncCallback callback) {
                 try {
                     latch.await();
                 } catch (InterruptedException e) {
-                    // ignore
+                    LOG.info("Interrupted while waiting for the task to complete");
+                    Thread.currentThread().interrupt();
                 }
             }
         } else {

components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorReference.java

@@ -178,7 +178,8 @@ private void start() throws Exception {
                     }
                     eventHandlerStarted = true;
                 } catch (InterruptedException e) {
-                    //just retry
+                    LOGGER.info("Interrupted while waiting for the startup to complete");
+                    Thread.currentThread().interrupt();
                 }
             }
         }
@@ -317,7 +318,8 @@ private synchronized void shutdownDisruptor(boolean isReconfiguring) {
                         }
                         eventHandlerFinished = true;
                     } catch (InterruptedException e) {
-                        //just retry
+                        LOGGER.info("Interrupted while waiting for the shutdown to complete");
+                        Thread.currentThread().interrupt();
                     }
                 }
             }

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.");

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();
     }