2017-04-26 1 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

관련 문제