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 e8724613dcc8c498263379ba113bf5477c44f4cc Author: PyvesB <[email protected]> AuthorDate: Thu Dec 7 11:56:57 2017 +0000 CAMEL-12071 improved unit tests for createQueue --- .../camel/component/aws/sqs/SqsEndpointTest.java | 26 ++++++++++++++++++++++ 1 file changed, 26 insertions(+) diff --git a/components/camel-aws/src/test/java/org/apache/camel/component/aws/sqs/SqsEndpointTest.java b/components/camel-aws/src/test/java/org/apache/camel/component/aws/sqs/SqsEndpointTest.java index d7122e1..18aef1e 100644 --- a/components/camel-aws/src/test/java/org/apache/camel/component/aws/sqs/SqsEndpointTest.java +++ b/components/camel-aws/src/test/java/org/apache/camel/component/aws/sqs/SqsEndpointTest.java @@ -110,4 +110,30 @@ public class SqsEndpointTest { Mockito.verify(amazonSQSClient).createQueue(expectedCreateQueueRequest); assertEquals("https://sqs.us-east-1.amazonaws.com/111222333/test-queue.fifo";, endpoint.getQueueUrl()); } + + @Test + public void createQueueShouldCreateStandardQueueWithCorrectAttributes() { + config.setDefaultVisibilityTimeout(1000); + config.setMaximumMessageSize(128); + config.setMessageRetentionPeriod(1000); + config.setPolicy("{\"Version\": \"2012-10-17\"}"); + config.setReceiveMessageWaitTimeSeconds(5); + config.setRedrivePolicy("{ \"deadLetterTargetArn\" : String, \"maxReceiveCount\" : Integer }"); + + CreateQueueRequest expectedCreateQueueRequest = new CreateQueueRequest("test-queue") + .addAttributesEntry(QueueAttributeName.VisibilityTimeout.name(), "1000") + .addAttributesEntry(QueueAttributeName.MaximumMessageSize.name(), "128") + .addAttributesEntry(QueueAttributeName.MessageRetentionPeriod.name(), "1000") + .addAttributesEntry(QueueAttributeName.Policy.name(), "{\"Version\": \"2012-10-17\"}") + .addAttributesEntry(QueueAttributeName.ReceiveMessageWaitTimeSeconds.name(), "5") + .addAttributesEntry(QueueAttributeName.RedrivePolicy.name(), "{ \"deadLetterTargetArn\" : String, \"maxReceiveCount\" : Integer }"); + Mockito.when(amazonSQSClient.createQueue(expectedCreateQueueRequest)) + .thenReturn(new CreateQueueResult() + .withQueueUrl("https://sqs.us-east-1.amazonaws.com/111222333/test-queue";)); + + endpoint.createQueue(amazonSQSClient); + + Mockito.verify(amazonSQSClient).createQueue(expectedCreateQueueRequest); + assertEquals("https://sqs.us-east-1.amazonaws.com/111222333/test-queue";, endpoint.getQueueUrl()); + } } \ No newline at end of file -- To stop receiving notification emails like this one, please contact "[email protected]" <[email protected]>.
