8.10. 배치 메시지 보내기
You can set a SendMessageBatchRequest or an Iterable
from("direct:start")
.setHeader(SqsConstants.SQS_OPERATION, constant("sendBatchMessage"))
.process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
Collection c = new ArrayList();
c.add("team1");
c.add("team2");
c.add("team3");
c.add("team4");
exchange.getIn().setBody(c);
}
})
.to("aws2-sqs://camel-1?accessKey=RAW(xxx)&secretKey=RAW(xxx)®ion=eu-west-1");
그 결과, SendMessageBatchResponse 인스턴스가 포함된 교환을 받을 수 있습니다. 시험에서 어떤 메시지가 성공했는지와 그렇지 않은지 확인할 수 있습니다. 배치의 각 메시지에 설정된 id는 Random UUID가 됩니다.