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;
}