You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2020/10/08 05:28:15 UTC
[camel] 01/02: CAMEL-15558 pollEnrich timeout issue (#4389)
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 <ch...@gmail.com>
AuthorDate: Thu Oct 8 10:49:46 2020 +0530
CAMEL-15558 pollEnrich timeout issue (#4389)
Co-authored-by: Chandrakant Hardahe <ch...@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();