You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@servicemix.apache.org by Tomasz Prus <to...@gmail.com> on 2008/10/31 12:19:35 UTC
JMSCorrelationId
hi,
I have aggregator that aggregate messages from different providers eg.
hotels, flights .. but it aggregate all messages from several
requests. How to implement JMSCorrelationId that aggregator take
messages only for one request. We don't know when but we loose
JMSCorrelationId (seted in soap client).
SoapClient (getPackage) -> splitter (getFlights, getHotels..) ->
aggregator (join messages from flights, hotels..) -> SoapClient
Please help me! Our project stopped in progress because we cannot
implement aggregator. Where can i see some working example?
Re: JMSCorrelationId
Posted by Tomasz Prus <to...@gmail.com>.
We try to use marshalers for every bc unit to handle JMSCorrelationID.
Is it good way, do we need these or async-bridge resolve problem
without marshalers?
2008/11/3 Tomasz Prus <to...@gmail.com>:
> Is there something like async-bridge in camel?
>
> 2008/11/1 Guillaume Nodet <gn...@gmail.com>:
>> I suppose you use a request / response mechanism on the soap side.
>> You would need to use the EIP async bridge which is able to convert an
>> incoming InOut exchange to an InOnly exchange and wait for a
>> correlated InOnly exchange to come back.
>> So the soap consumer endpoint would target the eip async bridge, which
>> in turn would go to splitter, the flights and hotels services, then go
>> to an eip aggregator and back to the async bridge. The async would
>> send back the response to the soap consumer.
>>
>> On Fri, Oct 31, 2008 at 12:19 PM, Tomasz Prus <to...@gmail.com> wrote:
>>> hi,
>>>
>>> I have aggregator that aggregate messages from different providers eg.
>>> hotels, flights .. but it aggregate all messages from several
>>> requests. How to implement JMSCorrelationId that aggregator take
>>> messages only for one request. We don't know when but we loose
>>> JMSCorrelationId (seted in soap client).
>>>
>>> SoapClient (getPackage) -> splitter (getFlights, getHotels..) ->
>>> aggregator (join messages from flights, hotels..) -> SoapClient
>>>
>>> Please help me! Our project stopped in progress because we cannot
>>> implement aggregator. Where can i see some working example?
>>>
>>
>>
>>
>> --
>> Cheers,
>> Guillaume Nodet
>> ------------------------
>> Blog: http://gnodet.blogspot.com/
>> ------------------------
>> Open Source SOA
>> http://fusesource.com
>>
>
Re: JMSCorrelationId
Posted by Tomasz Prus <to...@gmail.com>.
Is there something like async-bridge in camel?
2008/11/1 Guillaume Nodet <gn...@gmail.com>:
> I suppose you use a request / response mechanism on the soap side.
> You would need to use the EIP async bridge which is able to convert an
> incoming InOut exchange to an InOnly exchange and wait for a
> correlated InOnly exchange to come back.
> So the soap consumer endpoint would target the eip async bridge, which
> in turn would go to splitter, the flights and hotels services, then go
> to an eip aggregator and back to the async bridge. The async would
> send back the response to the soap consumer.
>
> On Fri, Oct 31, 2008 at 12:19 PM, Tomasz Prus <to...@gmail.com> wrote:
>> hi,
>>
>> I have aggregator that aggregate messages from different providers eg.
>> hotels, flights .. but it aggregate all messages from several
>> requests. How to implement JMSCorrelationId that aggregator take
>> messages only for one request. We don't know when but we loose
>> JMSCorrelationId (seted in soap client).
>>
>> SoapClient (getPackage) -> splitter (getFlights, getHotels..) ->
>> aggregator (join messages from flights, hotels..) -> SoapClient
>>
>> Please help me! Our project stopped in progress because we cannot
>> implement aggregator. Where can i see some working example?
>>
>
>
>
> --
> Cheers,
> Guillaume Nodet
> ------------------------
> Blog: http://gnodet.blogspot.com/
> ------------------------
> Open Source SOA
> http://fusesource.com
>
Re: JMSCorrelationId
Posted by Guillaume Nodet <gn...@gmail.com>.
I suppose you use a request / response mechanism on the soap side.
You would need to use the EIP async bridge which is able to convert an
incoming InOut exchange to an InOnly exchange and wait for a
correlated InOnly exchange to come back.
So the soap consumer endpoint would target the eip async bridge, which
in turn would go to splitter, the flights and hotels services, then go
to an eip aggregator and back to the async bridge. The async would
send back the response to the soap consumer.
On Fri, Oct 31, 2008 at 12:19 PM, Tomasz Prus <to...@gmail.com> wrote:
> hi,
>
> I have aggregator that aggregate messages from different providers eg.
> hotels, flights .. but it aggregate all messages from several
> requests. How to implement JMSCorrelationId that aggregator take
> messages only for one request. We don't know when but we loose
> JMSCorrelationId (seted in soap client).
>
> SoapClient (getPackage) -> splitter (getFlights, getHotels..) ->
> aggregator (join messages from flights, hotels..) -> SoapClient
>
> Please help me! Our project stopped in progress because we cannot
> implement aggregator. Where can i see some working example?
>
--
Cheers,
Guillaume Nodet
------------------------
Blog: http://gnodet.blogspot.com/
------------------------
Open Source SOA
http://fusesource.com
Re: JMSCorrelationId
Posted by Tomasz Prus <to...@gmail.com>.
I thouth ServiceMix itself handle message correlation and identity?
2008/10/31 Java Programmer <jp...@gmail.com>:
> On Fri, Oct 31, 2008 at 12:19 PM, Tomasz Prus <to...@gmail.com> wrote:
>> hi,
>>
>> I have aggregator that aggregate messages from different providers eg.
>> hotels, flights .. but it aggregate all messages from several
>> requests. How to implement JMSCorrelationId that aggregator take
>> messages only for one request. We don't know when but we loose
>> JMSCorrelationId (seted in soap client).
>
> Hi,
> You must write your own marshaller, because ServiceMix do not provide
> JMSCorrelationID. Do you have one?
>
> Best regards,
> Adr
>
Re: JMSCorrelationId
Posted by Java Programmer <jp...@gmail.com>.
On Fri, Oct 31, 2008 at 12:19 PM, Tomasz Prus <to...@gmail.com> wrote:
> hi,
>
> I have aggregator that aggregate messages from different providers eg.
> hotels, flights .. but it aggregate all messages from several
> requests. How to implement JMSCorrelationId that aggregator take
> messages only for one request. We don't know when but we loose
> JMSCorrelationId (seted in soap client).
Hi,
You must write your own marshaller, because ServiceMix do not provide
JMSCorrelationID. Do you have one?
Best regards,
Adr