[camel] branch master updated: CAMEL-14984 Sqs2EndpointBuilder is not respecting delay - polling continuously (#3792)

[davsclaus]

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 08a41ad  CAMEL-14984 Sqs2EndpointBuilder is not respecting delay - 
polling continuously (#3792)
08a41ad is described below

commit 08a41adf596808a2b99f5da0d6439b81eda2ef2d
Author: Chandrakant Hardahe <chandrakanthardah...@gmail.com>
AuthorDate: Fri May 1 10:11:03 2020 +0530

    CAMEL-14984 Sqs2EndpointBuilder is not respecting delay - polling 
continuously (#3792)
    
    Co-authored-by: Chandrakant Hardahe <chard...@chardahe.pnq.csb>
---
 .../main/java/org/apache/camel/component/aws2/sqs/Sqs2Endpoint.java   | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Endpoint.java
 
b/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Endpoint.java
index b191dc2..b5a3fdb 100644
--- 
a/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Endpoint.java
+++ 
b/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Endpoint.java
@@ -105,6 +105,10 @@ public class Sqs2Endpoint extends ScheduledPollEndpoint 
implements HeaderFilterS
         configureConsumer(sqsConsumer);
         sqsConsumer.setMaxMessagesPerPoll(maxMessagesPerPoll);
         DefaultScheduledPollConsumerScheduler scheduler = new 
DefaultScheduledPollConsumerScheduler();
+        scheduler.setDelay(sqsConsumer.getDelay());
+        scheduler.setUseFixedDelay(sqsConsumer.isUseFixedDelay());
+        scheduler.setInitialDelay(sqsConsumer.getInitialDelay());
+        scheduler.setTimeUnit(sqsConsumer.getTimeUnit());
         scheduler.setConcurrentTasks(configuration.getConcurrentConsumers());
         sqsConsumer.setScheduler(scheduler);
         return sqsConsumer;