Author: gertv
Date: Tue Dec 30 07:51:25 2008
New Revision: 730157
URL: http://svn.apache.org/viewvc?rev=730157&view=rev
Log:
CAMEL-1199: Fixing bug I just introduced
Modified:
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Throttler.java
Modified:
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Throttler.java
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Throttler.java?rev=730157&r1=730156&r2=730157&view=diff
==============================================================================
---
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Throttler.java
(original)
+++
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Throttler.java
Tue Dec 30 07:51:25 2008
@@ -20,8 +20,6 @@
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
/**
* A <a href="http://activemq.apache.org/camel/throttler.html";>Throttler</a>
@@ -110,7 +108,7 @@
// we're at the start of a new time period
// so lets reset things
requestCount.set(0);
- startTimeMillis.set(0);
+ startTimeMillis.set(now);
} else {
if (requestCount.incrementAndGet() > maximumRequestsPerPeriod) {
// lets sleep until the start of the next time period
