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
의 인스턴스화에 관한 메시지. 그러나 아무 일도 일어나지 않습니다. 나는 소비 된 메시지에 관한 메시지를 얻지 못한다.
무엇이 문제입니까?
대기열에서 소비 할 메시지가 있습니까? –