Camel Java DSL:使用响应中的值更新下一个轮询请求参数



我是Apache Camel的新手,这就是我要弄清楚的。在下面的示例代码中,我试图在下一个轮询请求中的请求参数中使用属性 - "值"。

String valueFromTheResponse= ""
m.addRouteBuilder(new RouteBuilder() {
        @Override
        public void configure() throws Exception {
            from("timer://foo?period=2)
            .setHeader(Exchange.CONTENT_TYPE, constant("application/json"))
            .setHeader("Accept", constant("application/json"))
            .to("https4://" + <myrequestURL>?param=<valueFromTheResponse>)
            .marshal().json(JsonLibrary.Jackson)
            .setProperty("value", jsonpath("$.value"))
            .process(new Processor() {
                @Override
                public void process(final Exchange exchange) throws Exception {
                    valueFromTheResponse = (String) exchange.getProperty("value");
                }
            })
        }
    });
    m.run();

实现这一目标的最佳方法是什么?或分配类级变量属性值?

更新:解决方案通过添加以下内容来使其正常工作:

.process(new Processor() {
                @Override
                public void process(final Exchange exchange) throws Exception {
                    exchange.getIn().setHeader("CamelHttpQuery", buildParamQuery());
                }
            })

您需要将值存储在共享字段中,例如RouteBuilder类本身或共享类实例。然后在到http 端点URI中,您需要将param查询设置为消息标头,而不是可以通过方法调用获得该值。

.setHeader(Exchange.HTTP_QUERY, method(this, "buildParamQuery"))

,然后有一个方法

public String buildParamQuery() {
  return "param=" + sharedValue;
}

然后,您可以从带有最后一个值的内线处理器设置此字段。并介绍初始值,例如第一个民意测验值为null,因此您可能需要从buildParamQuery方法或其他内容返回一个空字符串/null。

最新更新