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)&region=eu-west-1");

因此，您将收到一个包含 SendMessageBatchResponse 实例的交换，您可以检查哪些消息是成功的，哪些消息是什么。批处理每条消息上设置的 id 将是一个 Random UUID。