駱駝：路由前修改輸出

駱駝路由器我有下面的路由。駱駝：路由前修改輸出

from("jetty:http://localhost:9092?matchOnUriPrefix=true"). 
    to("http://server:9093/service1?bridgeEndpoint=true&throwExceptionOnFailure=false") 
    .to("http://server:9094/service2?bridgeEndpoint=true&throwExceptionOnFailure=false") 
    .to("log:output")

上述路由工作正常。

但我的要求是在發送到service2之前修改service1的輸出。就像如果我得到 <x>abc</x>

我必須把它轉換成

<y><x>abc</x></y>

我使用處理器試過，但我得到的exchange.getOut（）用於服務2爲空，而實際上它返回的XML。

有人可以幫助我，如果這是可能的？如果問題不明確，請告知我。

來源

2013-03-31 Java Beginner

你可以顯示你的處理器代碼。 – techuser

Hi @ user-soma，以下是我的處理器代碼。 '.process（新處理器（）{ \t \t \t \t \t \t @Override \t \t \t公共無效處理（交易交換）拋出異常{ \t \t \t \t消息中= exchange.getOut（）; \t \t \t \t \t \t \t \t exchange.getOut（）。setBody（共nvertIncomingRequestToOutgoingRequest（in.getBody（IncomingRequest.class）））; \t \t \t}' –

我不確定在路由中添加此處理器的位置。進入處理器的消息可在交換機上的信息中找到。我看到你正試圖從外面傳遞信息。

當您在外出消息上設置主體時，它在下一個端點或處理器的交換機上的消息中可用，因此必須拾取交換機上的正確消息。

下面的路線應該是有意義的，否則貼在你的問題處理器沿着整個路線，成員可以看到的問題是：

from("jetty:http://localhost:9092?matchOnUriPrefix=true") 
    .to("http://server:9093/service1?bridgeEndpoint=true&throwExceptionOnFailure=false"). 
     process(new Processor() { 
     public void process(Exchange exchange) throws Exception { 
      String body = exchange.getIn().getBody(String.class); 
      exchange.getOut().setBody(modifyBody(body); 
     } 
     }) 
    .to("http://server:9094/service2?bridgeEndpoint=true&throwExceptionOnFailure=false") 
    .to("log:output");

其中modifyBody將是將執行一個自定義的方法所需的轉換。

來源

2013-04-01 01:42:28 techuser

駱駝：路由前修改輸出

回答

相關問題