[camel] branch main updated: CAMEL-18875: camel-jms - Logging less noisy when temporary reply queue is refreshed

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 8b6ef2ad8ff CAMEL-18875: camel-jms - Logging less noisy when temporary 
reply queue is refreshed
8b6ef2ad8ff is described below

commit 8b6ef2ad8ffb07ea5a8f323051f9f1bfcea936fa
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Tue Jan 10 20:36:43 2023 +0100

    CAMEL-18875: camel-jms - Logging less noisy when temporary reply queue is 
refreshed
---
 .../component/jms/reply/TemporaryQueueReplyManager.java    | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git 
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java
 
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java
index 6cddd1b1d4d..e62b840ce85 100644
--- 
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java
+++ 
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/TemporaryQueueReplyManager.java
@@ -53,7 +53,8 @@ public class TemporaryQueueReplyManager extends 
ReplyManagerSupport {
         try {
             destResolver.destinationReady();
         } catch (InterruptedException e) {
-            log.warn("Interrupted while waiting for JMSReplyTo destination 
refresh", e);
+            log.warn("Interrupted while waiting for JMSReplyTo destination 
refresh due to: " + e.getMessage()
+                     + ". This exception is ignored.");
         }
         return super.getReplyTo();
     }
@@ -88,7 +89,7 @@ public class TemporaryQueueReplyManager extends 
ReplyManagerSupport {
         } else {
             // we could not correlate the received reply message to a matching 
request and therefore
             // we cannot continue routing the unknown message
-            // log a warn and then ignore the message
+            // log warn and then ignore the message
             log.warn("Reply received for unknown correlationID [{}]. The 
message will be ignored: {}", correlationID, message);
         }
     }
@@ -249,8 +250,13 @@ public class TemporaryQueueReplyManager extends 
ReplyManagerSupport {
         @Override
         public void onException(JMSException exception) {
             // capture exceptions, and schedule a refresh of the ReplyTo 
destination
-            log.warn("Exception inside the DMLC for Temporary ReplyTo Queue 
for destination {}, refreshing ReplyTo destination",
-                    endpoint.getDestinationName(), exception);
+            String msg
+                    = "Exception inside the DMLC for Temporary ReplyTo Queue 
for destination " + endpoint.getDestinationName()
+                      + ", refreshing ReplyTo destination (stacktrace in DEBUG 
logging level).";
+            log.warn(msg);
+            if (log.isDebugEnabled()) {
+                log.debug(msg, exception);
+            }
             destResolver.scheduleRefresh();
             // serve as a proxy for any exception listener the user may have 
set explicitly
             if (delegate != null) {