I guess it's caused by the stream is not been cached.
Please try to enable the streamCaching in your route like this
<route errorHandlerRef="deadLetterErrorHandler" streamCaching="true">
   <from ref="routerEndpoint"/>
   <to uri="http://localhost:8889/app"/>
   <multicast parallelProcessing="true">
                 <to uri="activemq:queue:log.out.A?requestTimeout=0"/>
                 <process ref="myProcessorOut"/>
   </multicast>
</route>

Willem

pevgen wrote:
> 
> pevgen wrote:
>> Hello, all.
>>
>> I wrote a route into my spring-config file :
>>
>> ....
>> <bean id="myProcessorOut" class="ru.transsys.testcxf.MyProcessorOut"/>
>>
>> <camel:camelContext xmlns="http://activemq.apache.org/camel/schema/spring";
>> id="camel">
>>
>> <endpoint id="routerEndpoint" uri="cxf:bean:routerEndpointConfig"/>
>>
>> <route errorHandlerRef="deadLetterErrorHandler">
>>   <from ref="routerEndpoint"/>
>>   <to uri="http://localhost:8889/app"/>
>>   <multicast parallelProcessing="true">
>>                 <to uri="activemq:queue:log.out.A?requestTimeout=0"/>
>>                 <process ref="myProcessorOut"/>
>>   </multicast>  
>> </route>
>>
>> </camel:camelContext>
>> ...
>>
>> My problem is an empty string here (the variable "body" = "") : 
>>
>>    String body = exchange.getIn().getBody(String.class);
>>
>> into "ru.transsys.testcxf.MyProcessorOut", but a log-AMQ-message have this
>> http-response.
>> And type of exchange is CxfExchange.
>>
>> Haw can a get http-response in my processor ?
>>
>> Thanks,
>> Evgeny
>>
>>
> 
> It's a strange situation, but if i commment "<to
> uri="activemq:queue:log.out.A?requestTimeout=0"/>", then  i get a normal
> string-request from the http-EP in my Processor...
> 
> I don't understand it...
> 
> Evgeny
> 

Reply via email to