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

Reply via email to