Multithreaded Resequencer with sequence key

[max_from_sumy]

Hi,

Please, help to implement next use case with Spring Integration:

I need to process messages coming to channel in multiple threads but messages with same sequence key (can be calculated via XPath expression on message body) should be processed strictly sequentially.

Are there any ways to do it with existing patterns, please, advise what classes to look for this functionality for.

Thanks is advance.

[oleg.zhurakousky]

Have you looked at the Priority Channel? http://static.springsource.org/sprin...mplementations

[max_from_sumy]

Thanks for quick reply Oleg.

So if I will configure priority channel:

<channel id="simpleChannel">
    <priority-queue capacity="100" comparator="com.xxx.OrderProcessingComparator"/>
</channel>

Does it means if I configure multi-threaded consuming on this channel - messages which are equal according to OrderProcessingComparator#compare() can be processed simultaneously?

[oleg.zhurakousky]

Actually thinking about it more, priority channel is not what you need. How many different combinations of this 'sequence key' can you have? Is it totally arbitrary or is it something more controlled and in the range of let's say 5-10 different combinations?

[max_from_sumy]

Hi Oleg,

Thank you for supporting.

Sequence key is just some specific value inside document body - this is some way to group documents together with the requirement that documents from 1 group should be processed 1-by-1 (order does not matter) but documents from different groups can be processed simultaneously.

So sequence key is totally arbitrary and we don't have any specific range for this.
Sequence key can be considered as "group id" to identify messages from same group.

[oleg.zhurakousky]

Let me sleep on it fro a few days. I need to think, but i'll definitely follow up.

[max_from_sumy]

Thanks a lot, will be waiting for reply.

[oleg.zhurakousky]

If you don't hear from me, just ping on this thread and i'll get a reminder

[max_from_sumy]

Hi Oleg,

Do you have an idea on how to implement the desirable?

Thanks in advance for your help.

[max_from_sumy]

Hi Oleg,

If you will have an idea on this, please, reply.

Thanks.