camel
を使用してメッセージを使用しています。Amazon SQS
です。ハンドラは次のようになりますキューからメッセージが消えません
<from uri="aws-sqs://{{aws.sqs.queue}}?amazonSQSClient=#sqsClient&delay=10000"/>
<to uri="bean:sqsQueueListener?method=consumeMessage(${body})"/>
class SqsQueueListener {
@Handler
public void consumeMessage(List<Message> messages) {
LOGGER.info("Got messages: [{}].", messages);
}
}
私が得るすべての10 seconds
を(注釈がそれを扱う必要がありますが、それは動作しませんでしたので、私はもともとので、私はそれを直接定義されたxml
でそれを指定しませんでした)キューから読み込もうとしているときに、アプリケーション内のクライアントAmazonSQS
のインスタンス化に関するメッセージ。しかし、何も起こりません。私は消費されたメッセージについてのメッセージを取得しません。
何が問題ですか?
キューから消費されるメッセージはありますか? –