Re: Enabling Message Groups

2013-10-06 Thread Girish
Okay, so looks like this is governed by maxPageSize for the queue .. the messages from the fetched page alone seem to be getting considered for group assignment and load balancing ... similar issue/limitation exists for message selectors -- View this message in context: http://activemq.2283324.

Re: Message group not working when first group has large number of messages

2013-10-06 Thread Girish
Going by the older discussion around similar problem faced in case of message selectors, it seems that maxPageSize is the one causing this effect i.e. the messages from fetched page are getting considered for group assignment and consumer load balancing I increased this limit to > 20k and now

Pending Message ?

2013-10-06 Thread darkrwe
Hello guys ! I'm using activeMQ cms c++ libraries and ActiveMQ 5.8.0 as a broker. Summary of what i'm doing is: I have created an connection in main process in my project. I passed the this connection to a thread and also created a fork process from this thread. But in this child process when i j

ActiveMQ, how can i delete alle consumers in my queue ?

2013-10-06 Thread stargate
Hi, i working with JEE and tomcat and i have created a jmsproducer and a consumer for my jms queue. I create the consumer with a singleton pattern so that i have only one consumer. But my problem is, every time i undeploy the war file and upload a new war file to my server it add`s a new consumer

Re: Pending Message ?

2013-10-06 Thread darkrwe
I think the problem is about *forking* and all address space of parent process copied to fork process: But the interesting thing is that i just send the pointer of my connection and session to thread and this child process just used main process's connection and session and its consumer/producers