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

apache · Jan 11, 2024 · 558e5b3 · 558e5b3
1 parent 8623fa3
commit 558e5b3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/...cast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueConsumer.java b/...cast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueConsumer.java
@@ -97,7 +97,7 @@ public void run() {
                             }
                         }
                     } catch (InterruptedException e) {
-                        // ignore
+                        Thread.currentThread().interrupt();
                     }
                 }
             }

diff --git a/...elcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaConsumer.java b/...elcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaConsumer.java
@@ -132,6 +132,7 @@ public void done(boolean asyncDone) {
                 if (LOG.isDebugEnabled()) {
                     LOG.debug("Hzlq Consumer Interrupted: {}", e, e);
                 }
+                Thread.currentThread().interrupt();
                 continue;
             } catch (Exception e) {
                 // Rollback
@@ -145,7 +146,8 @@ public void done(boolean asyncDone) {
                 getExceptionHandler().handleException("Error processing exchange", exchange, e);
                 try {
                     Thread.sleep(endpoint.getConfiguration().getOnErrorDelay());
-                } catch (InterruptedException ignore) {
+                } catch (InterruptedException ie) {
+                    Thread.currentThread().interrupt();
                 }
             }
         }