camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ge...@apache.org
Subject svn commit: r730157 - /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Throttler.java
Date Tue, 30 Dec 2008 15:51:25 GMT
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



Mime
View raw message