Как получить атрибут сообщения AWS sqs в Java верблюда DSL? - PullRequest
Новая
       65

Как получить атрибут сообщения AWS sqs в Java верблюда DSL?

0 голосов
/ 24 сентября 2019

Я отправил атрибут сообщения в квадраты AWS вместе с телом, используя команду Apache camel ниже команды

to("aws-sqs://{{queue.name}}?amazonSQSClient=#sqsClient&attributeNames=#systemName")

Сообщение успешно отправлено.Теперь я хочу получить атрибут сообщения systemName , используя Camel DSL Java.Но не в состоянии восстановить это. CamelAwsSqsAttributes и CamelAwsSqsMessageAttributes оба остаются пустыми в заголовке.Ниже приведен код Потребитель 

Main main = new Main();
        main.bind("sqsAttributeNames", Collections.singletonList("All"));
        main.bind("sqsMessageAttributeNames", Collections.singletonList("All"));

    from("aws-sqs://a{{queue.name}}?" +
            "amazonSQSClient=#sqsClient&attributeNames=#sqsAttributeNames&messageAttributeNames=#sqsMessageAttributeNames")
            .log("We have a failed request message in queue ${headers}")

Может кто-нибудь помочь мне в этом ??

...