camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Claus Ibsen <claus.ib...@gmail.com>
Subject Re: aws-sqs producer does not support new FIFO queues
Date Tue, 02 May 2017 18:45:10 GMT
Hi

Can you set the header yourself, eg setHeader("MessageGroupId",
constant("something"))

I am not sure if the camel-aws component is supposed to set some group
id by itself. Isn't that intended to be set by the end user to
something relevant about the message, such as customId or appId or
something.

On Tue, May 2, 2017 at 12:27 PM, ecorengia <emiliocorengia@gmail.com> wrote:
> Hi all, I have being using aws-sqs component without problems on the past
> using standard SQS queues.
>
> But now, I'm not able to send messages to the new FIFO queue mechanism
> available on some regions.
>
> I have tried the consumer piece, and that seems to be okay. The problems is
> with the producer. When I try to send a new message I get an error saying
> "The request must contain the parameter MessageGroupId".
>
> I'm using Camel version 2.18.3. This is my test route:
>
>     from("direct:" + ROUTE_ID + "_send_sync_notification")
>         .routeId(ROUTE_ID + "_send_sync_notification")
>         .process(exchange -> exchange.getIn().getHeaders().clear())
>
> .to("aws-sqs://{{SQS_fifo_queue}}?amazonSQSClient=#myClient&region=us-east-2");
>
> Stacktrace is copied below. Do you know if it is a known issue or if I'm
> missing something? I couldn't find this problem on your issue tracker.
>
> Thanks! Emilio.
>
> [2017-05-02 13:18:43.040] boot - 18028  WARN [Camel (TitlesIntegration)
> thread #38 - Multicast] --- DeadLetterChannel: Failed delivery for
> (MessageId: ID-ecorengia-laptop-37936-1493741878671-0-23 on ExchangeId:
> ID-ecorengia-laptop-37936-1493741878671-0-24). On delivery attempt: 0
> caught: com.amazonaws.AmazonServiceException: The request must contain the
> parameter MessageGroupId. (Service: AmazonSQS; Status Code: 400; Error Code:
> MissingParameter; Request ID: 2b1a16b0-cf4c-5115-9b90-47327cee3ec9)
> com.amazonaws.AmazonServiceException: The request must contain the parameter
> MessageGroupId. (Service: AmazonSQS; Status Code: 400; Error Code:
> MissingParameter; Request ID: 2b1a16b0-cf4c-5115-9b90-47327cee3ec9)
>         at
> com.amazonaws.http.AmazonHttpClient.handleErrorResponse(AmazonHttpClient.java:1378)
>         at
> com.amazonaws.http.AmazonHttpClient.executeOneRequest(AmazonHttpClient.java:924)
>         at
> com.amazonaws.http.AmazonHttpClient.executeHelper(AmazonHttpClient.java:702)
>         at com.amazonaws.http.AmazonHttpClient.doExecute(AmazonHttpClient.java:454)
>         at
> com.amazonaws.http.AmazonHttpClient.executeWithTimer(AmazonHttpClient.java:416)
>         at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:365)
>         at
> com.amazonaws.services.sqs.AmazonSQSClient.doInvoke(AmazonSQSClient.java:1741)
>         at
> com.amazonaws.services.sqs.AmazonSQSClient.invoke(AmazonSQSClient.java:1711)
>         at
> com.amazonaws.services.sqs.AmazonSQSClient.sendMessage(AmazonSQSClient.java:1487)
>         at
> org.apache.camel.component.aws.sqs.SqsProducer.process(SqsProducer.java:62)
>         at
> org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)
>         at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:145)
>         at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
>         at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:542)
>         at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)
>         at org.apache.camel.processor.Pipeline.process(Pipeline.java:120)
>         at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
>         at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)
>         at
> org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:62)
>         at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:145)
>         at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
>         at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)
>         at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:542)
>         at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)
>         at
> org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:681)
>         at
> org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:609)
>         at
> org.apache.camel.processor.MulticastProcessor.process(MulticastProcessor.java:238)
>         at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
>         at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)
>         at org.apache.camel.processor.Pipeline.process(Pipeline.java:120)
>         at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
>         at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)
>         at
> org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:62)
>         at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:145)
>         at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
>         at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:542)
>         at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)
>         at org.apache.camel.processor.Pipeline.process(Pipeline.java:120)
>         at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
>         at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:542)
>         at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)
>         at
> org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:681)
>         at
> org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:609)
>         at
> org.apache.camel.processor.MulticastProcessor.process(MulticastProcessor.java:238)
>         at org.apache.camel.processor.Splitter.process(Splitter.java:108)
>         at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
>         at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:542)
>         at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)
>         at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)
>         at
> org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:62)
>         at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:145)
>         at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
>         at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:542)
>         at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)
>         at org.apache.camel.processor.Pipeline.process(Pipeline.java:120)
>         at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
>         at org.apache.camel.processor.LoopProcessor.process(LoopProcessor.java:128)
>         at org.apache.camel.processor.LoopProcessor.process(LoopProcessor.java:96)
>         at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
>         at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:542)
>         at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)
>         at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)
>         at
> org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:62)
>         at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:145)
>         at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
>         at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)
>         at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:542)
>         at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)
>         at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:109)
>         at
> org.apache.camel.processor.MulticastProcessor.doProcessParallel(MulticastProcessor.java:827)
>         at
> org.apache.camel.processor.MulticastProcessor.access$200(MulticastProcessor.java:85)
>         at
> org.apache.camel.processor.MulticastProcessor$1.call(MulticastProcessor.java:320)
>         at
> org.apache.camel.processor.MulticastProcessor$1.call(MulticastProcessor.java:305)
>         at java.util.concurrent.FutureTask.run(FutureTask.java:266)
>         at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
>         at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
>         at java.lang.Thread.run(Thread.java:745)
>
>
>
>
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/aws-sqs-producer-does-not-support-new-FIFO-queues-tp5798568.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-----------------
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2

Mime
View raw message