骆驼SQS解组

Question

 from("aws-sqs://test-camel-start?amazonSQSClient=#sqsClient&concurrentConsumers=2&maxMessagesPerPoll=1")
            .unmarshal()
            .base64()
            .process(new BaseProcessor())
            .to("aws-sqs://test-camel-success?amazonSQSClient=#sqsClient").end();

我的测试处理器：

 public boolean process(Exchange exchange, AsyncCallback callback) {
    try {
        String header = (String) exchange.getIn().getHeader("CamelAwsSqsMessageId");
        String message = exchange.getIn().getBody(String.class);
        MDC.put("message-id", header);
        Thread.sleep(5 * 1000);
        LOG.info("Async ping");
        LOG.info(message);
    } catch (Throwable e) {
        LOG.error(e.getMessage(), e);
        exchange.setException(e);
    }
    callback.done(false);
    return false;
}

所以我有下一种情况：1）骆驼成功地从“test-camel-start”队列读取消息2）基处理器成功地处理消息3）在重试将消息传递到“test-camel-success”时失败

我收到了下一个日志跟踪：

Log说“请求必须包含参数MessageBody”。

我不知道为什么这个消息体没有出现。

Answer 1

请参阅以下常见问题解答：http://camel.apache.org/why-is-my-message-body-empty.html

在处理器中，您可以将消息正文转换为记录的字符串。由于消息主体是基于流的（例如base64的输出），它将读取主体到流的结尾，然后消息将被视为空的。

您可以在处理器中打开流缓存或不进行此手动日志记录。