7.10. 배치 메시지 전송
SendMessageBatchRequest 또는 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가 됩니다.