You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2017/12/07 14:08:16 UTC
[camel] 02/03: CAMEL-12071 improved unit tests for createQueue
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 <pi...@bbc.co.uk>
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
"commits@camel.apache.org" <co...@camel.apache.org>.