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 <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.
>
