8.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 将是一个随机 UUID。