Reputation: 135
My application requires that all messages with a particular group id be processed by the same thread. I tried to set this up using the DMLC, but as I am seeing messages being processed, they are being handled by separate threads within DMLC when concurrency is set > 1. My hope was that I could have multiple consumers reading from the queue each with different message groups, but I am not seeing the desired behavior with this setup. Is there a way using DMLC or SMLC (with JTA) to support multiple listeners on a queue where all messages with a particular group id are handled by the same thread, without setting the concurrency to 1? I'm nearing the point where I believe SMLC and DMLC will not meet this need and I will need to use a different implementation to handle this case. Are there any examples or advice on doing this?
Upvotes: 2
Views: 140
Reputation: 174664
Can you post your code that exhibits this behavior? I just ran a test while answering this question and it works perfectly fine for me with all messages for the same group going to the same thread.
Upvotes: 0