Hi,
I'm very new to JMS and activeMQ. I have some questions regarding
Cache,Acknowledged, and Prefetch limit
Here is my scenario.
1. I'm using Apache Activemq 5.5.0
2. Let's say I have 1500 messages in a queue (test.testQ).
For the first 1499 messages, I set message.setStringProperty("type","0").
For the last message (1500th), "type" string property is set to "1".
3. I create one consumer with Session.CLIENT_ACKNOWLEDGE and receive
messages in a while loop consumer.receive(timeoutMs) method with a timeout
of 10s.
Note that I haven't acknowledged any message in my scenario.
For example,
cf = new ActiveMQConnectionFactory("tcp://192.168.9.12:61616");
queue = new ActiveMQQueue("test.testQ");
connection = cf.createConnection();
session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
messageConsumer = session.createConsumer(queue,null);
int count = 0;
while( (cMessage = messageConsumer.receive(10000)) != null)
cCount++;
}
Here is my questions.
1. The cCount result is 675. What configurations contribute to the limit of
675 result count instead of 1500? What should I do if I want to see all
those messages (1500 as a result).
I've tried
cf.getPrefetchPolicy().setQueuePrefetch(5000);
and
queue = new ActiveMQQueue("test.testQ?consumer.prefetchSize=5000");
but still get the same result of 675.
2. I've read a description of prefetch limit from
http://activemq.apache.org/what-is-the-prefetch-limit-for.html
Based on my understanding, if I set the prefetch size to 1 for example,
cf.getPrefetchPolicy().setQueuePrefetch(1);
and
queue = new ActiveMQQueue("test.testQ?consumer.prefetchSize=1");
I should see the cCount result of 1 since I haven't acknowledged any
message. Am I correct?
3. What is the best way for me to get to the 1500th message if a lot of
messages in front of it are not acknowledged yet?
I've tried message selector, for example
messageConsumer = session.createConsumer(queue,"type='1'");
But it doesn't return the message. I think this is due to prefetch limit. Am
I right?
Ideally, I don't want to increase prefetch limit, does anyone know a way to
use message selector to ask Message Broker to push the client certain
messages directly without getting into prefetch limit on the client side? I
assume there is a message consumer internal queue in ActiveMQ to support
this prefetch. Basically, I'd like to know if there is a way to by pass it.
Thank you in advance for your help!
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Questions-about-Cache-Acknowledged-and-Prefetch-limit-tp3472368p3472368.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
