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
