camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Hervé BARRAULT <herve.barra...@gmail.com>
Subject Re: Multicast And Activemq
Date Mon, 16 Jan 2012 12:05:40 GMT
Hi,
I have tested like described in
http://camel.apache.org/recipient-list.html#RecipientList-Sendingtomultiplerecipientsinparallel
and it is working.

I had a strange behavior because i had an error in the consumer configuration.

Thank you for the help.


On 1/16/12, Claus Ibsen <claus.ibsen@gmail.com> wrote:
> Hi
>
> You should not do both multicast + recipient list.
> The recipient list also has the parallel processing. So just use that EIP
> only.
>
>
> On Mon, Jan 16, 2012 at 11:32 AM, Hervé BARRAULT
> <herve.barrault@gmail.com> wrote:
>> Hi,
>> I used parallel processing like shown in
>> http://camel.apache.org/multicast.html without timeout.
>>
>> [quote]
>> .process(myProcessor_)
>> .multicast()
>> .parallelProcessing()
>> .recipientList(header(TARGET_HEADER));
>> [/quote]
>>
>> Regards
>>
>> On 1/16/12, Claus Ibsen <claus.ibsen@gmail.com> wrote:
>>> Hi
>>>
>>> You need to use the parallelProcessing option as documented on the
>>> wiki pages for those EIPs.
>>>
>>>
>>> On Mon, Jan 16, 2012 at 11:20 AM, Hervé BARRAULT
>>> <herve.barrault@gmail.com> wrote:
>>>> Hi,
>>>> I have a question concerning camel camel-core (2.4.0.fuse-00-00) ,
>>>> activemq camel activemq-camel (5.4.0.fuse-00-00) and activemq
>>>> activemq-core (5.4.0.fuse-00-00).
>>>>
>>>> I am trying to use multicast.
>>>>
>>>> I had a route :
>>>>
>>>> from(sourceUri_)
>>>>            .errorHandler(noErrorHandler())
>>>>            .policy(getTracePolicy())
>>>>            .policy(getErrorReportingPolicy())
>>>>            .process(myProcessor_)
>>>>            .recipientList(header(TARGET_HEADER));
>>>>
>>>> But when sending to n target queues, we noticed that the behavior is
>>>> sequential (normal).
>>>>
>>>> Now we are trying to use multicast :
>>>> from(sourceUri_)
>>>>            .errorHandler(noErrorHandler())
>>>>            .policy(getTracePolicy())
>>>>            .policy(getErrorReportingPolicy())
>>>>            .process(myProcessor_)
>>>>            .multicast()
>>>>            .parallelProcessing()
>>>>            .recipientList(header(TARGET_HEADER));
>>>>
>>>>
>>>> In this case the message is correctly send to the expected queues (in
>>>> my test 2) but only one queue is consumed.
>>>> For information the processor send itself a generated message in
>>>> another queue, and we are using one way.
>>>>
>>>> Is the right method to use multicast ? Is there something else to do ?
>>>>
>>>> Thanks for answers.
>>>>
>>>> Regards
>>>> Hervé
>>>
>>>
>>>
>>> --
>>> Claus Ibsen
>>> -----------------
>>> FuseSource
>>> Email: cibsen@fusesource.com
>>> Web: http://fusesource.com
>>> Twitter: davsclaus, fusenews
>>> Blog: http://davsclaus.blogspot.com/
>>> Author of Camel in Action: http://www.manning.com/ibsen/
>>>
>
>
>
> --
> Claus Ibsen
> -----------------
> FuseSource
> Email: cibsen@fusesource.com
> Web: http://fusesource.com
> Twitter: davsclaus, fusenews
> Blog: http://davsclaus.blogspot.com/
> Author of Camel in Action: http://www.manning.com/ibsen/
>

Mime
View raw message