diff --git a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/ReplyManagerSupport.java b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/ReplyManagerSupport.java index 42219a2fb9413..18b05d58fa04b 100644 --- a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/ReplyManagerSupport.java +++ b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/ReplyManagerSupport.java @@ -104,7 +104,7 @@ public Destination getReplyTo() { log.trace("Waiting for replyTo to be set done"); } } catch (InterruptedException e) { - // ignore + Thread.currentThread().interrupt(); } return replyTo; } diff --git a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/TemporaryQueueReplyManager.java b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/TemporaryQueueReplyManager.java index eadbd23869f8d..6c3ce420c1e06 100644 --- a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/TemporaryQueueReplyManager.java +++ b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/reply/TemporaryQueueReplyManager.java @@ -46,6 +46,7 @@ public Destination getReplyTo() { destResolver.destinationReady(); } catch (InterruptedException e) { log.warn("Interrupted while waiting for JMSReplyTo destination refresh", e); + Thread.currentThread().interrupt(); } return super.getReplyTo(); }