You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2008/10/08 21:04:35 UTC
svn commit: r702969 -
/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java
Author: davsclaus
Date: Wed Oct 8 12:04:34 2008
New Revision: 702969
URL: http://svn.apache.org/viewvc?rev=702969&view=rev
Log:
CAMEL-951: BatchProcessor using TRACE logging for polling
Modified:
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java
Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java?rev=702969&r1=702968&r2=702969&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java (original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java Wed Oct 8 12:04:34 2008
@@ -141,15 +141,15 @@
for (int i = 0; !isBatchCompleted(i); i++) {
long timeout = end - System.currentTimeMillis();
if (timeout < 0L) {
- if (LOG.isDebugEnabled()) {
- LOG.debug("batch timeout expired at batch index: " + i);
+ if (LOG.isTraceEnabled()) {
+ LOG.trace("batch timeout expired at batch index: " + i);
}
break;
}
Exchange exchange = consumer.receive(timeout);
if (exchange == null) {
- if (LOG.isDebugEnabled()) {
- LOG.debug("receive with timeout: " + timeout + " expired at batch index: " + i);
+ if (LOG.isTraceEnabled()) {
+ LOG.trace("receive with timeout: " + timeout + " expired at batch index: " + i);
}
break;
}