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 07e3d064bd495bcab50250e583938d937be0b24d Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Thu May 3 13:25:45 2018 +0200 Fixed CS and regen --- .../org/apache/camel/component/aws/sqs/SqsConfiguration.java | 2 +- .../camel/component/aws/sqs/SqsEndpointExplicitQueueUrlTest.java | 4 ++-- .../component/aws/sqs/springboot/SqsComponentConfiguration.java | 9 +++++++++ 3 files changed, 12 insertions(+), 3 deletions(-) diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsConfiguration.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsConfiguration.java index 4d9839d..6c02929 100644 --- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsConfiguration.java +++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsConfiguration.java @@ -347,7 +347,7 @@ public class SqsConfiguration implements Cloneable { public void setConcurrentConsumers(int concurrentConsumers) { this.concurrentConsumers = concurrentConsumers; } - + /** * To define the queueUrl explicitly. All other parameters, which would influence the queueUrl, are ignored. * This parameter is intended to be used, to connect to a mock implementation of SQS, for testing purposes. diff --git a/components/camel-aws/src/test/java/org/apache/camel/component/aws/sqs/SqsEndpointExplicitQueueUrlTest.java b/components/camel-aws/src/test/java/org/apache/camel/component/aws/sqs/SqsEndpointExplicitQueueUrlTest.java index 7674360..61a314e 100644 --- a/components/camel-aws/src/test/java/org/apache/camel/component/aws/sqs/SqsEndpointExplicitQueueUrlTest.java +++ b/components/camel-aws/src/test/java/org/apache/camel/component/aws/sqs/SqsEndpointExplicitQueueUrlTest.java @@ -18,10 +18,10 @@ package org.apache.camel.component.aws.sqs; import com.amazonaws.services.sqs.AmazonSQSClient; import org.apache.camel.impl.DefaultCamelContext; -import org.mockito.Mockito; import org.junit.Assert; import org.junit.Before; import org.junit.Test; +import org.mockito.Mockito; public class SqsEndpointExplicitQueueUrlTest extends Assert { @@ -47,4 +47,4 @@ public class SqsEndpointExplicitQueueUrlTest extends Assert { assertEquals(endpoint.getQueueUrl(), QUEUE_URL); } -} \ No newline at end of file +} diff --git a/platforms/spring-boot/components-starter/camel-aws-starter/src/main/java/org/apache/camel/component/aws/sqs/springboot/SqsComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-aws-starter/src/main/java/org/apache/camel/component/aws/sqs/springboot/SqsComponentConfiguration.java index 1db47e5..37cc16e 100644 --- a/platforms/spring-boot/components-starter/camel-aws-starter/src/main/java/org/apache/camel/component/aws/sqs/springboot/SqsComponentConfiguration.java +++ b/platforms/spring-boot/components-starter/camel-aws-starter/src/main/java/org/apache/camel/component/aws/sqs/springboot/SqsComponentConfiguration.java @@ -208,6 +208,7 @@ public class SqsComponentConfiguration */ private String region; private Integer concurrentConsumers = 1; + private String queueUrl; private String proxyHost; private Integer proxyPort; @@ -388,6 +389,14 @@ public class SqsComponentConfiguration this.concurrentConsumers = concurrentConsumers; } + public String getQueueUrl() { + return queueUrl; + } + + public void setQueueUrl(String queueUrl) { + this.queueUrl = queueUrl; + } + public String getProxyHost() { return proxyHost; } -- To stop receiving notification emails like this one, please contact acosent...@apache.org.