Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (nike.apache.org: domain of fancyerii@gmail.com designates
 209.85.215.53 as permitted sender)
MIME-Version: 1.0
In-Reply-To: 
 <CAF7Ov00ggfHG3uCj5kN-Ud6oFrDP-uFF6kc3LSavf7sk0OXe7Q@mail.gmail.com>
References: 
 <CAFAd71XZKay9+8+1sFt16TbEkDHyq_v_ZgK8FcNSCERz0=S2hw@mail.gmail.com>
	<CAF7Ov00ggfHG3uCj5kN-Ud6oFrDP-uFF6kc3LSavf7sk0OXe7Q@mail.gmail.com>
Date: Wed, 5 Mar 2014 17:46:19 +0800
Message-ID: 
 <CAFAd71Uw5RwmtR6oNXofbJdJH+t_KK3NFXM0A+VjX_+G6t5dqg@mail.gmail.com>
Subject: Re: is tens of thousands of session feasible?
From: Li Li <fancyerii@gmail.com>
To: users@activemq.apache.org
Content-Type: text/plain; charset=ISO-8859-1

If I have one session and a receiver thread. this thread receive ten
messages to ten worker thread.
each worker thread acknowledge it's message?
receiver thread:
while(true){
      Message msg=receiver.receive();
      put msg to a ConcurrentLinkedList;

Worker thread:
while(true){
     Message msg=getMessgeFromLinkedList();
     process msg;
     msg.acknowledge();
}


On Wed, Mar 5, 2014 at 5:08 PM, Noel OConnor <noel.oconnor@gmail.com> wrote:
> have you seen ActiveMQSession.INDIVIDUAL_ACKNOWLEDGE
>
> see
> http://activemq.apache.org/maven/apidocs/org/apache/activemq/ActiveMQSession.html#INDIVIDUAL_ACKNOWLEDGE
>
>
> On Wed, Mar 5, 2014 at 6:48 PM, Li Li <fancyerii@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.
>>