我已经发送消息属性到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}")
有人能帮我吗??
配置看起来不错,除了Collection应该用逗号分隔的字符串替换(确保字符串之间没有空格)。
另外,请提及您想要的属性。所有可能都不起作用。
Main main = new Main();
main.bind("sqsAttributeNames", "Attr1,Attr2");
main.bind("sqsMessageAttributeNames", "Attr1,Attr2");
请遵循最新的Camel-SQS组件。