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 2021/11/04 17:33:21 UTC
[camel] 02/04: CAMEL-17167 - Camel-AWS2-SQS: Message attributes can
be at most 10
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit ea77ffb4df4665a6b54ea2a3c996b3419b9f1976
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Nov 4 16:46:15 2021 +0100
CAMEL-17167 - Camel-AWS2-SQS: Message attributes can be at most 10
---
.../SqsProducerSendLocalstackMaxAttributesIT.java | 19 ++++++++++++++++++-
1 file changed, 18 insertions(+), 1 deletion(-)
diff --git a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/integration/SqsProducerSendLocalstackMaxAttributesIT.java b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/integration/SqsProducerSendLocalstackMaxAttributesIT.java
index 544e18a..72a63b9 100644
--- a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/integration/SqsProducerSendLocalstackMaxAttributesIT.java
+++ b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/integration/SqsProducerSendLocalstackMaxAttributesIT.java
@@ -16,9 +16,15 @@
*/
package org.apache.camel.component.aws2.sqs.integration;
-import org.apache.camel.*;
+
+import org.apache.camel.EndpointInject;
+import org.apache.camel.Exchange;
+import org.apache.camel.ExchangePattern;
+import org.apache.camel.Processor;
+import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
+import org.junit.Assert;
import org.junit.jupiter.api.Test;
public class SqsProducerSendLocalstackMaxAttributesIT extends Aws2SQSBaseTest {
@@ -32,6 +38,16 @@ public class SqsProducerSendLocalstackMaxAttributesIT extends Aws2SQSBaseTest {
@Test
public void sendInOnly() throws Exception {
result.expectedMessageCount(1);
+ result.expectedHeaderReceived("value1", "value1");
+ result.expectedHeaderReceived("value2", "value2");
+ result.expectedHeaderReceived("value3", "value3");
+ result.expectedHeaderReceived("value4", "value4");
+ result.expectedHeaderReceived("value5", "value5");
+ result.expectedHeaderReceived("value6", "value6");
+ result.expectedHeaderReceived("value7", "value7");
+ result.expectedHeaderReceived("value8", "value8");
+ result.expectedHeaderReceived("value9", "value9");
+ result.expectedHeaderReceived("value10", "value10");
Exchange exchange = template.send("direct:start", ExchangePattern.InOnly, new Processor() {
public void process(Exchange exchange) throws Exception {
@@ -51,6 +67,7 @@ public class SqsProducerSendLocalstackMaxAttributesIT extends Aws2SQSBaseTest {
});
assertMockEndpointsSatisfied();
+ Assert.assertNull(result.getExchanges().get(0).getMessage().getHeader("value11"));
}
@Override