Camel处理器未设置标头

Question

    <routeContext xmlns="http://camel.apache.org/schema/spring"
    id="routes1">

    <route id="sdPoll" de:name="Polling"
        de:systemName="Polling" streamCache="true">
        <from uri="timer://sdPoll?fixedRate=true&amp;period=60000" />
        <process ref="refProcessor" />
        <to uri="http://dummyhost" />
        <to uri="log:DEBUG?showBody=true&amp;showHeaders=true" />
    </route>
</routeContext>
<bean id="refProcessor"
    class="com.abc.de.RefProcessor" />

public class RefProcessor implements Processor {

private final Logger log = Logger.getLogger(RefProcessor.class);

@SuppressWarnings("unchecked")
@Override
public void process(Exchange exchange) throws Exception {

    exchange.getIn().setHeader("Authorization", "TODO");
    exchange.getIn().setHeader("CamelHttpMethod", "POST");
    exchange.getIn().setHeader("CamelHttpUri", "http://localhost:8280/api/check");
    exchange.getIn().setHeader("Content-Type", "application/json");
    exchange.getIn().setHeader("Accept", "application/json");
    exchange.getIn().setBody("TODO");

    //exchange.getOut().setHeaders(exchange.getIn().getHeaders());
    //exchange.getOut().setHeader("Authorization", "TODO");
    //exchange.getOut().setBody("TODO");
 }
}

日志-消息历史记录路由ID处理器ID处理器运行(ms)[sdPoll][sdPoll][Timer://sdPoll？FixedRate=true&period=60000][21176][null][onCompletion1][onCompletion][106][sdPoll][process7][Ref:RefProcessor][21067][null][process3][Ref:GenericErrorHandle][21016]

Exchange[Id ID-ABC-63143-1516034486954-0-2 ExchangePattern InOnly头{breadcrumbid=ID-ABC-63143-1516034486954-0-1，camelredelivered=false，camelredeliverycounter=0，Firedtime=mon 1月15日11:41:31 EST 2018}BodyType null Body[Body is null]]

Java DSL似乎可以工作！那么我的Spring DSL配置有什么问题

static RouteBuilder createRouteBuilder3() {
    return new RouteBuilder() {
        public void configure() {
            from("timer://timer1?period=60000").process(new Processor() {
                public void process(Exchange exchange) throws UnsupportedEncodingException {
                    exchange.getIn().setHeader("CamelHttpMethod", "POST");
                    exchange.getIn().setHeader("Content-Type", "application/json");
                    exchange.getIn().setHeader("Accept", "application/json");
                    exchange.getIn().setHeader("CamelHttpUri",
                            "http://localhost:8280/api/check");
                    exchange.getIn().setHeader("Authorization", "TODO");

                    exchange.getIn().setBody("TODO");
                }
            }).to("http://dummyhost").to("log:DEBUG?showBody=true&showHeaders=true");
        }
    };
}

消息历史记录RouteId ProcessorId处理器运行(ms)[route1][route1][timer://timer1？period=60000][86][route1][process1][refprocessorcamel$3$1@258e2e41][6][route1][to1][http://dummyhost][76]

Exchange[Id ID-ABC-63940-1516036107063-0-2 ExchangePattern InOnly Headers{accept=application/json,authorization=TODO,breadcrumbid=id-ABC-63994-1516036220042-0-1,camelhttpmethod=post,camelhttpuri=http://localhost:8280/api/check,camelredelivered=false,camelredeliverycounter=0,content-type=application/json,firedtime=mon 1月15日12:10:21 EST 2018}

Answer 1

你的处理器看起来没问题。

只是胡乱猜测，但您是否有意在XML配置中使用routeContext？如果没有，可以尝试切换到CamelContext吗？

有关RouteContext和CamelContext之间的区别，请参见http://people.apache.org/~dkulp/camel/configuring-camel.html