This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit a9cec274a3e02e04a8abca75b8e94e1820d83da6 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Fri Nov 27 19:27:15 2020 +0100 Fixed CS --- .../camel/component/aws2/sqs/Sqs2Producer.java | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java b/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java index 2bec75b..abd7962 100644 --- a/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java +++ b/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java @@ -173,18 +173,18 @@ public class Sqs2Producer extends DefaultProducer { private void configureFifoAttributes(SendMessageRequest.Builder request, Exchange exchange) { if (getEndpoint().getConfiguration().isFifoQueue()) { // use strategies - if (ObjectHelper.isNotEmpty(getEndpoint().getConfiguration().getMessageGroupIdStrategy())) { - MessageGroupIdStrategy messageGroupIdStrategy = getEndpoint().getConfiguration().getMessageGroupIdStrategy(); - String messageGroupId = messageGroupIdStrategy.getMessageGroupId(exchange); - request.messageGroupId(messageGroupId); - } + if (ObjectHelper.isNotEmpty(getEndpoint().getConfiguration().getMessageGroupIdStrategy())) { + MessageGroupIdStrategy messageGroupIdStrategy = getEndpoint().getConfiguration().getMessageGroupIdStrategy(); + String messageGroupId = messageGroupIdStrategy.getMessageGroupId(exchange); + request.messageGroupId(messageGroupId); + } - if (ObjectHelper.isNotEmpty(getEndpoint().getConfiguration().getMessageDeduplicationIdStrategy())) { - MessageDeduplicationIdStrategy messageDeduplicationIdStrategy - = getEndpoint().getConfiguration().getMessageDeduplicationIdStrategy(); - String messageDeduplicationId = messageDeduplicationIdStrategy.getMessageDeduplicationId(exchange); - request.messageDeduplicationId(messageDeduplicationId); - } + if (ObjectHelper.isNotEmpty(getEndpoint().getConfiguration().getMessageDeduplicationIdStrategy())) { + MessageDeduplicationIdStrategy messageDeduplicationIdStrategy + = getEndpoint().getConfiguration().getMessageDeduplicationIdStrategy(); + String messageDeduplicationId = messageDeduplicationIdStrategy.getMessageDeduplicationId(exchange); + request.messageDeduplicationId(messageDeduplicationId); + } } }