This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push: new 7bfc65c CAMEL-14984: Same fix in camel-ironmq 7bfc65c is described below commit 7bfc65cde7374a96d4e1ac5a7a8f68d7b6f2f5e5 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Fri May 1 06:54:00 2020 +0200 CAMEL-14984: Same fix in camel-ironmq --- .../main/java/org/apache/camel/component/ironmq/IronMQEndpoint.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/components/camel-ironmq/src/main/java/org/apache/camel/component/ironmq/IronMQEndpoint.java b/components/camel-ironmq/src/main/java/org/apache/camel/component/ironmq/IronMQEndpoint.java index acc7c34..8f72c4d 100644 --- a/components/camel-ironmq/src/main/java/org/apache/camel/component/ironmq/IronMQEndpoint.java +++ b/components/camel-ironmq/src/main/java/org/apache/camel/component/ironmq/IronMQEndpoint.java @@ -62,9 +62,12 @@ public class IronMQEndpoint extends ScheduledPollEndpoint { configureConsumer(ironMQConsumer); ironMQConsumer.setMaxMessagesPerPoll(configuration.getMaxMessagesPerPoll()); DefaultScheduledPollConsumerScheduler scheduler = new DefaultScheduledPollConsumerScheduler(); + scheduler.setDelay(ironMQConsumer.getDelay()); + scheduler.setUseFixedDelay(ironMQConsumer.isUseFixedDelay()); + scheduler.setInitialDelay(ironMQConsumer.getInitialDelay()); + scheduler.setTimeUnit(ironMQConsumer.getTimeUnit()); scheduler.setConcurrentTasks(configuration.getConcurrentConsumers()); ironMQConsumer.setScheduler(scheduler); - return ironMQConsumer; }