svn commit: r1358190 - /camel/trunk/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsProducer.java

[davsclaus]

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