camel-commits mailing list archives

Author: davsclaus
Date: Fri Jul  6 13:23:11 2012
New Revision: 1358190

URL: http://svn.apache.org/viewvc?rev=1358190&view=rev
Log:
Polished

Modified:
    camel/trunk/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsProducer.java

Modified: camel/trunk/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsProducer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsProducer.java?rev=1358190&r1=1358189&r2=1358190&view=diff
==============================================================================
--- camel/trunk/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsProducer.java
(original)
+++ camel/trunk/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsProducer.java
Fri Jul  6 13:23:11 2012
@@ -102,7 +102,7 @@ public class HdfsProducer extends Defaul
         if (idleStrategy != null) {
             scheduler = getEndpoint().getCamelContext().getExecutorServiceManager().newSingleThreadScheduledExecutor(this,
"HdfsIdleCheck");
             log.debug("Creating IdleCheck task scheduled to run every {} millis", config.getCheckIdleInterval());
-            scheduler.scheduleAtFixedRate(new IdleCheck(idleStrategy), 1000, config.getCheckIdleInterval(),
TimeUnit.MILLISECONDS);
+            scheduler.scheduleAtFixedRate(new IdleCheck(idleStrategy), config.getCheckIdleInterval(),
config.getCheckIdleInterval(), TimeUnit.MILLISECONDS);
         }
     }