Sorry to hijack this thread, but after several attempts, unsubscribe from this list continues to fail. Please unsubscribe my email from this list.
On Mar 5, 2014, at 2:08 AM, Noel OConnor <noel.ocon...@gmail.com> wrote: > have you seen ActiveMQSession.INDIVIDUAL_ACKNOWLEDGE > > see > https://urldefense.proofpoint.com/v1/url?u=http://activemq.apache.org/maven/apidocs/org/apache/activemq/ActiveMQSession.html%23INDIVIDUAL_ACKNOWLEDGE&k=wlPCrglRP6kzT4RbABWMaw%3D%3D%0A&r=BNcu0LfT1bojlTvn%2Bonyd8NiumDMDaY101M3AeCHhDo%3D%0A&m=h4Q%2B5DpuQOJVlHuAvdGaeAsxszqDYuzRukSyfeED0xA%3D%0A&s=a454f8b3097af04c24c9bf004ae6b8ae73c7abca16de8dce930af44e5c9ce69d > > > On Wed, Mar 5, 2014 at 6:48 PM, Li Li <fancye...@gmail.com> wrote: > >> hi all, >> I want to process a batch of message using my own priority >> algorithm. But in JMS, I can't acknowledge a single message and can >> only acknowledge a session. So I decide to do it like this: >> 1. Create N(=10000) sessions >> 2. using a thread to manage session acknowledge like: >> for(int i=0;i<N;i++){ >> if session acknowledged{ >> receive A Message without waiting; >> put this message to my own priority queue; >> } >> } >> 3. using another thread to process my own queue; >> get a message from my own queue; >> process this message; >> get the session of this message; >> acknowledge this session; >> >> because a session will receive only a message a time and it >> will be blocked until this message is processed. I need create many >> sessions(maybe I can make session a pool) . I don't know whether >> activemq can deal with so much session. for a single consumer, I will >> create 10000 session. if I have ten consumers, then 100,000 session be >> created at the same time. >> NOTICE: This email message is for the sole use of the intended recipient(s) and may contain confidential and privileged information. Any unauthorized review, use, disclosure or distribution is prohibited. If you are not the intended recipient, please contact the sender by reply email and destroy all copies of the original message.
