0
我试图使用camel
来消费Amazon SQS
的消息。队列中没有消息
<from uri="aws-sqs://{{aws.sqs.queue}}?amazonSQSClient=#sqsClient&delay=10000"/>
<to uri="bean:sqsQueueListener?method=consumeMessage(${body})"/>
处理程序看起来像这样(我原本并没有xml
指定它,因为注解应该有处理它,但它没有工作,所以我就直接将它定义)
class SqsQueueListener {
@Handler
public void consumeMessage(List<Message> messages) {
LOGGER.info("Got messages: [{}].", messages);
}
}
每10 seconds
我得到的关于在我的应用程序中实例化AmazonSQS
客户端的消息,因为它正尝试从队列中读取。但是没有任何反应。我没有收到关于消费信息的消息。
什么问题?
是否有消息要从队列中消耗? –