You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2024/01/11 16:55:34 UTC
(camel) 05/07: CAMEL-20297 camel-hazelcast: do not swallow interrupted exceptions
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 558e5b3283f8a7ab7e181d7ec0889b9627f2b9b6
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Thu Jan 11 10:13:02 2024 +0100
CAMEL-20297 camel-hazelcast: do not swallow interrupted exceptions
---
.../camel/component/hazelcast/queue/HazelcastQueueConsumer.java | 2 +-
.../apache/camel/component/hazelcast/seda/HazelcastSedaConsumer.java | 4 +++-
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueConsumer.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueConsumer.java
index e177126b1ae..856767a6712 100644
--- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueConsumer.java
+++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueConsumer.java
@@ -97,7 +97,7 @@ public class HazelcastQueueConsumer extends HazelcastDefaultConsumer {
}
}
} catch (InterruptedException e) {
- // ignore
+ Thread.currentThread().interrupt();
}
}
}
diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaConsumer.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaConsumer.java
index a4528c5445c..f8eed4ef240 100644
--- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaConsumer.java
+++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaConsumer.java
@@ -132,6 +132,7 @@ public class HazelcastSedaConsumer extends DefaultConsumer implements Runnable {
if (LOG.isDebugEnabled()) {
LOG.debug("Hzlq Consumer Interrupted: {}", e, e);
}
+ Thread.currentThread().interrupt();
continue;
} catch (Exception e) {
// Rollback
@@ -145,7 +146,8 @@ public class HazelcastSedaConsumer extends DefaultConsumer implements Runnable {
getExceptionHandler().handleException("Error processing exchange", exchange, e);
try {
Thread.sleep(endpoint.getConfiguration().getOnErrorDelay());
- } catch (InterruptedException ignore) {
+ } catch (InterruptedException ie) {
+ Thread.currentThread().interrupt();
}
}
}