[camel] 01/02: CAMEL-15558 pollEnrich timeout issue (#4389)

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch camel-3.4.x
in repository https://gitbox.apache.org/repos/asf/camel.git

commit b4f59494ef2fbcc7a5fc42a1baae2ea9954d5256
Author: Chandrakant Hardahe <chandrakanthardah...@gmail.com>
AuthorDate: Thu Oct 8 10:49:46 2020 +0530

    CAMEL-15558 pollEnrich timeout issue (#4389)
    
    Co-authored-by: Chandrakant Hardahe <chard...@chardahe.pnq.csb>
---
 .../org/apache/camel/component/file/GenericFilePollingConsumer.java   | 2 +-
 .../src/main/java/org/apache/camel/support/ScheduledPollEndpoint.java | 4 ++++
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/components/camel-file/src/main/java/org/apache/camel/component/file/GenericFilePollingConsumer.java
 
b/components/camel-file/src/main/java/org/apache/camel/component/file/GenericFilePollingConsumer.java
index a19964b..95bbd6e 100644
--- 
a/components/camel-file/src/main/java/org/apache/camel/component/file/GenericFilePollingConsumer.java
+++ 
b/components/camel-file/src/main/java/org/apache/camel/component/file/GenericFilePollingConsumer.java
@@ -33,7 +33,7 @@ public class GenericFilePollingConsumer extends 
EventDrivenPollingConsumer {
 
     public GenericFilePollingConsumer(GenericFileEndpoint endpoint) throws 
Exception {
         super(endpoint);
-        this.delay = endpoint.getDelay();
+        this.delay = endpoint.getDefaultDelay();
     }
 
     @Override
diff --git 
a/core/camel-support/src/main/java/org/apache/camel/support/ScheduledPollEndpoint.java
 
b/core/camel-support/src/main/java/org/apache/camel/support/ScheduledPollEndpoint.java
index 5b0b5c3..f25221f 100644
--- 
a/core/camel-support/src/main/java/org/apache/camel/support/ScheduledPollEndpoint.java
+++ 
b/core/camel-support/src/main/java/org/apache/camel/support/ScheduledPollEndpoint.java
@@ -191,6 +191,10 @@ public abstract class ScheduledPollEndpoint extends 
DefaultEndpoint {
         }
     }
 
+    public long getDefaultDelay() {
+        return (getDelay() == -1) ? DEFAULT_DELAY : getDelay();
+    }
+
     @Override
     protected void doStart() throws Exception {
         super.doStart();