如何将请求数据从spring boot controller传递到apache camel路由

Question

用例：在我的应用程序中，有一个REST控制器，是在Spring boot的帮助下开发的，我的要求是，我必须将请求数据从控制器传递到路由，从路由再次需要将数据传递到MQ

在这里，我如何将inputReq数据从控制器传递到路由？谁能帮忙吗

@Controller
public class RequestController {

    @PostMapping("/request")
    public String requestMapping(@RequestBody String inputReq) {
        new ProduceRouter();  // instance of the apache camel route
        return null;

    }
}

下面是阿帕奇骆驼路线：

@Component
public class ProduceRouter extends RouteBuilder {

    @Override
    public void configure() throws Exception {
            
        .from("jms:RequestQueue?disableReplyTo=true")
        .log("Received Body is  ${body}   and header info is   ${headers}  ");

        

    }
}

Answer 1

在控制器中，自动连接CamelContext和ProducerTemplate的实例。

@Autowired
private CamelContext camelContext;
@Autowired
private ProducerTemplate producer;

然后需要使用ExchangeBuilder创建一个交换请求，并添加请求正文。

Exchange exchangeRequest = ExchangeBuilder.anExchange(camelContext)
.withBody(inputReq).build();

然后，您可以调用生产者对象上的发送方法来访问您的路由并捕获响应。

Exchange exchangeResponse = producer.send("direct:startRoute", exchangeRequest).

然后在路由文件中，您可以从direct:startRoute