提问者:小点点

如何检索aws sqs消息属性骆驼DSLjava?


我已经发送消息属性到AWSsqs随着身体使用Apache骆驼下面的命令

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

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}")

有人能帮我吗??


共1个答案

匿名用户

配置看起来不错,除了Collection应该用逗号分隔的字符串替换(确保字符串之间没有空格)。

另外,请提及您想要的属性。所有可能都不起作用。

    Main main = new Main();
    main.bind("sqsAttributeNames", "Attr1,Attr2");
    main.bind("sqsMessageAttributeNames", "Attr1,Attr2");

请遵循最新的Camel-SQS组件。