Oct 12th, 2012, 06:11 AM
Spring Integration and Spring Batch remote chunking
I have already posted this in spring batch forum but did not really get definitive answer. As it is also related to spring integration I am posting it also here.
Our requirement is to run same job that uses remote-chunking with different data in parallel (=different job instances) and that works fine in Spring Batch alone.
Howvere I think that current implementation of remote-chunking provided by Spring Integration is not supporting it and I would say if that's the case that it breaks contract established by Spring Batch.
From what I see in code there is no way how to consume messages from the reply queue only for the specific job instance therefore if two jobs instances are running in parallel the would steal messages from each other.
I think that scenario mentioned above would be possible if messages are marked with correlation id = job instance id. Then consumers could filter messages using selectors.
Is that possible in spring batch integration without changing the code?
Has anyone came over the same problem?