0

我正在尝试将 Spring DSL 中的 Camel 路由转换为 Java DSL 中的等效路由。我完成了大部分翻译,但有一些我根本不知道该怎么做:更改标题。

以下是示例:

春季 DSL:

<bean id="service" class="org.apache.camel.example.service.Reporting" />
<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route id="mina1">
        <from uri="mina:tcp://localhost:9991" />
        <setHeader headerName="minaServer">
            <constant>localhost:9991</constant>
        </setHeader>
        <bean ref="service" method="updateReport" />
        <to uri="direct:messageSender1" />
    </route>
</camelContext>

Java DSL:

public void configure() throws Exception {
    from("mina:tcp://localhost:9991")
    .setHeader(Exchange.HTTP_METHOD, constant("localhost:9991"))
    .beanRef("camel_examples.loadbalancer_failover_javadsl.service.Reporting", "updateReport")
    .to("direct:messageSender1");
}

最后,使用 Header 的 bean 方法:

public Report updateReport(@Body Report report, @Header("minaServer") String name) {

    report.setReply("Report passed by MINA servers running on: " + name);
    return report;
}

现在,在使用 Spring DSL 的示例中,一切正常。但是在使用 Java DSL 的示例中,我根本无法正确设置标头。它只是没有发生。我知道这是行的原因.setHeader(Exchange.HTTP_METHOD, constant("localhost:9991")),可能是Exchange.HTTP_METHOD部分,但老实说,我也不知道该放什么。我也试过了Exchange.HTTP_URI,结果是一样的。

我的翻译有什么问题?

4

1 回答 1

1

尝试这个

.exchange.getIn().setHeader("minaServer", constant("localhost:9991"))
于 2013-11-06T23:10:21.803 回答