duplicate message processing in spring integration application in multiple tomcats -

duplicate message processing in spring integration application in multiple tomcats -

i have spring web/integration application. in order run long running processes in background, have used queue backed mongodbmessagestore , polls queue every 1 second.

i tried send messages(1000 messages per instance) gateway same application running on 2 tomcat instances. verified messages processed server 1, not beingness processed server 2 , vice versa. saw document stored in mongo collection. has uuid (message id) , _group_complete, not able conclude how spring avoids duplicate message processing if application running on multiple instances single momgodb instance.

appreciate help.

because mongodbmessagestore uses findandremove operation.

and that's expected behaviour distributed environment.

would worse if you'd opposite.

spring-integration