Could you set multipl eConsumers=true also on the producer (to("vm:..."))
side.

Best,
Christian

Sent from a mobile device
Am 16.05.2012 17:37 schrieb "Michael Süess" <michael.sue...@basis06.ch>:

> I use vm (or seda) with ?multipleConsumers=true to implement a
> request-reply observer pattern:
>
>
> <?xml version="1.0" encoding="UTF-8"?>
> <beans 
> xmlns="http://www.**springframework.org/schema/**beans<http://www.springframework.org/schema/beans>
> "
>       
> xmlns:xsi="http://www.w3.org/**2001/XMLSchema-instance<http://www.w3.org/2001/XMLSchema-instance>
> "
>       
> xmlns:camel="http://camel.**apache.org/schema/spring<http://camel.apache.org/schema/spring>
> "
>       xsi:schemaLocation="
>       
> http://www.springframework.**org/schema/beans<http://www.springframework.org/schema/beans>
> http://www.springframework.**org/schema/beans/spring-beans.**xsd<http://www.springframework.org/schema/beans/spring-beans.xsd>
>       
> http://camel.apache.org/**schema/spring<http://camel.apache.org/schema/spring>
> http://camel.apache.org/**schema/spring/camel-spring.xsd<http://camel.apache.org/schema/spring/camel-spring.xsd>
> **">
>    <camelContext 
> xmlns="http://camel.apache.**org/schema/spring<http://camel.apache.org/schema/spring>
> ">
>        <route id="subject">
>            <from uri="file:data/spike/in?noop=**true"/>
>            <log message="starting file '${header.CamelFileName}' ..."/>
>            <to uri="vm:subjectStarted" pattern="InOut"/>
>            <log message="file '${header.CamelFileName}' done"/>
>        </route>
>
>        <route id="subjectListener1">
>            <from uri="vm:subjectStarted?**multipleConsumers=true"/>
>            <log message="   starting file '${header.CamelFileName}' ..."/>
>            <log message="   file '${header.CamelFileName}' done"/>
>        </route>
>
>        <route id="subjectListener2">
>            <from uri="vm:subjectStarted?**multipleConsumers=true"/>
>            <log message="   starting file '${header.CamelFileName}' ..."/>
>            <log message="   file '${header.CamelFileName}' done"/>
>        </route>
>    </camelContext>
> </beans>
>
> when running this sample i always got an ExchangeTimedOutException
> although all listeners have finished before the timeout.
>
> Any ideas?
>

Reply via email to