아파치 카멜은 부두에서 빈 응답을받습니다.

Question

나는 복잡한 경우가 있습니다.

1) <from uri="jetty:http://0.0.0.0:30100/jetty/test"/>

2) <to uri="hazelcast-client:master-test-series" />

3) <to uri="bean:modelSeriesWrapperTest" />

4)

<split parallelProcessing="true" streaming="true">  
    <simple>${body}</simple> <to uri="direct:dw.model.test"/> 
    </split> 

5 : 내가 일을하고있어 다음 단계로이다) ~에서 anoth

<from uri="direct:dw.model.test"/> 
    <aggregate strategyRef="myAggregatorStrategy" 
       completionTimeout="1000"> 
       <correlationExpression> 
        <constant>true</constant> 
       </correlationExpression> 
       <marshal ref="modelSeriesVariantColourGson" /> 
       <camel:to uri="file:src/data/catask/output?fileName=output.xml"/> 
    </aggregate> 

문제 어 경로

는 부두 응답이 비어 있다는 것입니다. TCP 추적을 사용하여 요청 및 응답을 추적하지만 Content-Length는 0입니다. 그러나 output.xml 파일에는 올바른 JSON 형식 내용이 있습니다. 심지어 나는 <camel:to uri="file:src/data/catask/output?fileName=output.xml"/>를 교차시킵니다. 부두 반응은 아직 비어 있습니다.

InOut 패턴을 사용해도 잘 작동하지 않습니다. 부두가 곧 돌아오고, 기다리지 않아도됩니다. 나는 In과 Out 몸체를 설정하려고 시도하는데, 그것은 작동하지 않습니다. 나는 내가 할 수있는 모든 경우에 Google을 사용한다. 도움이되는 경우는 없습니다. 도와주세요. 고맙습니다.

• http://camel.apache.org/composed-message-processor.html

스플리터가 내장 된 통합 : 당신이 어 그리 게이터에서 어떤 정보를 포함하도록 부두 응답을 원하는 경우에 설명 된대로

Answer 1

, 당신은 스플리터에만 접근 방식을 사용해야합니다 , 그리고 그것은 스플리터가 완료되었을 때를 보장하고, 또한 집계하며,이를 스쿠터 응답으로 사용할 수 있습니다.

<aggregate>을 사용하면 별도의 교환이됩니다. 이것을 더 잘 이해하기 위해서는 집계 eip와 기타 SO, 다양한 Camel 책 등을 읽어보십시오.