2017-04-26 14 views
0

camelを使用してメッセージを使用しています。Amazon SQSです。ハンドラは次のようになりますキューからメッセージが消えません

<from uri="aws-sqs://{{aws.sqs.queue}}?amazonSQSClient=#sqsClient&amp;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のインスタンス化に関するメッセージ。しかし、何も起こりません。私は消費されたメッセージについてのメッセージを取得しません。

何が問題ですか?

+0

キューから消費されるメッセージはありますか? –

答えて

0

"sqsClient"という名前のラクダ文脈に添付されたレジストリにハンドラを追加しましたか?

+0

はい。私は春を使用しているので、アプリケーションのコンテキストからBeanを取得しているはずです – lapots

関連する問題