基于Camel的SQS路由与Base64解码实现技术咨询
Camel SQS路由与异步Processor技术问题咨询
我整理了一段简洁的Camel路由,它从指定SQS队列消费消息,执行Base64解码后交给自定义Processor处理,最终将处理后的消息发送到目标SQS队列,路由代码如下:
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();
对应的测试异步Processor代码如下(代码未完整):
public boolean process(Exchange exchange, AsyncCallback callback) { try { String header = (String) exchange.getIn().getHeader("CamelAwsSqsMessageId"); String message = exch...
现在针对这段Camel路由以及Processor的实现相关问题,希望能得到技术层面的解答。
内容的提问来源于stack exchange,提问作者denis
相关产品推荐
相关产品推荐

