camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r1327131 - /camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/ReplyManagerSupport.java
Date Tue, 17 Apr 2012 15:09:52 GMT
Author: davsclaus
Date: Tue Apr 17 15:09:52 2012
New Revision: 1327131

URL: http://svn.apache.org/viewvc?rev=1327131&view=rev
Log:
CAMEL-5141: camel-jms - Allow to configure frequency of timeout checker when doing request/reply
over JMS

Modified:
    camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/ReplyManagerSupport.java

Modified: camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/ReplyManagerSupport.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/ReplyManagerSupport.java?rev=1327131&r1=1327130&r2=1327131&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/ReplyManagerSupport.java
(original)
+++ camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/ReplyManagerSupport.java
Tue Apr 17 15:09:52 2012
@@ -30,6 +30,7 @@ import org.apache.camel.component.jms.Jm
 import org.apache.camel.component.jms.JmsMessage;
 import org.apache.camel.component.jms.JmsMessageHelper;
 import org.apache.camel.support.ServiceSupport;
+import org.apache.camel.util.ExchangeHelper;
 import org.apache.camel.util.ObjectHelper;
 import org.apache.camel.util.ServiceHelper;
 import org.slf4j.Logger;
@@ -117,8 +118,8 @@ public abstract class ReplyManagerSuppor
                     // timeout occurred do a WARN log so its easier to spot in the logs
                     if (log.isWarnEnabled()) {
                         log.warn("Timeout occurred after {} millis waiting for reply message
with correlationID [{}]."
-                                + " Setting ExchangeTimedOutException on ExchangeId: {} and
continue routing.",
-                                new Object[]{holder.getRequestTimeout(), holder.getCorrelationId(),
exchange.getExchangeId()});
+                                + " Setting ExchangeTimedOutException on {} and continue
routing.",
+                                new Object[]{holder.getRequestTimeout(), holder.getCorrelationId(),
ExchangeHelper.logIds(exchange)});
                     }
 
                     // no response, so lets set a timed out exception



Mime
View raw message