为什么setHeader在过程函数中不工作但功能不正常

我有一个小型骆驼项目，在该项目中，我从文件系统读取文件并在我的路径中处理它们。里面的处理功能我设置为什么setHeader在过程函数中不工作但功能不正常

exchange.getOut().setHeader("tc.GIARO.item.ids",simple("TC00000021"));

和事后。为了（）函数无法正常工作。但是，当我设置的处理功能外像

.setHeader("tc.GIARO.item.ids", simple("TC00000021"))

的。要（）函数识别该标头和作品。

，如果我的.log（）.process后直（）或.setHeader（）函数，它以两种方式注销..

有人知道为什么会这样？

编辑：

@Override 
public void configure() throws Exception { 

    from("file://" + path + "?preMove=inprogress&move=.done") 

      .process(new Processor() { 
       @Override 
       public void process(Exchange exchange) throws Exception { 
        String myFilename = (String) exchange.getIn().getHeader("CamelFileNameOnly"); 
        String[] tcid = myFilename.split("-"); 

        String filename = (String) exchange.getIn().getHeader("CamelFilePath"); 
        String content = new String(Files.readAllBytes(Paths.get(filename))); 

        exchange.getOut().setBody(content, String.class); 
        exchange.getOut().setHeader("tc.GIARO.item.ids", simple("TC00000021")); //whether here      
       } 
      }) 
      .setHeader("tc.GIARO.item.ids", simple("TC00000021")) // or whether here 
      .log("${header.tc.GIARO.item.ids}") 
      .to("tc://" + ip + "/tc?tcMethod=getItemAndRelatedObjects&tcUser=" + user + "&tcPass=" + pass 
        + "&tcSessionKey=1"); 
}

来源

2017-02-13 IVIike

很难说没有你的路线的其余部分。但是，我会建议你从getOut（）更改为getIn（），因为它是你想改变的部分。 – noMad17

你必须在的setHeader在邮件（未出消息）。不要创建一个新的Message（使用exchange.getOut().setSomething）

@Override 
public void configure() throws Exception { 

    from("file://" + path + "?preMove=inprogress&move=.done") 

      .process(new Processor() { 
       @Override 
       public void process(Exchange exchange) throws Exception { 
        String myFilename = (String) exchange.getIn().getHeader("CamelFileNameOnly"); 
        String[] tcid = myFilename.split("-"); 

        String filename = (String) exchange.getIn().getHeader("CamelFilePath"); 
        String content = new String(Files.readAllBytes(Paths.get(filename))); 

        exchange.getIn().setBody(content, String.class); 
        exchange.getIn().setHeader("tc.GIARO.item.ids", simple("TC00000021")); //whether here      
       } 
      }) 
      .setHeader("tc.GIARO.item.ids", simple("TC00000021")) // or whether here 
      .log("${header.tc.GIARO.item.ids}") 
      .to("tc://" + ip + "/tc?tcMethod=getItemAndRelatedObjects&tcUser=" + user + "&tcPass=" + pass 
        + "&tcSessionKey=1"); 
}

来源

2017-02-13 15:12:32

不，它不工作......我还设置了“exchange.getOut（）。setBody（content，String.class）;”这是工作 – IVIike

您是否正在创建一条新的Out消息？请发布你的'process'方法的代码。 –

看我的编辑：如果你做'exchange.getOut（）。setBody（content，String.class）;'它会创建一个新的消息。直接改变IN消息在骆驼中是可能的，因为它不介意。骆驼将检测到Exchange没有OUT消息，因此改为使用IN消息。看到这里：http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html –

为什么setHeader在过程函数中不工作但功能不正常

回答

相关问题