Re: Issue with MessageConsumer and MessageSelector

2015-12-24 Thread Tim Bain
How can you say that "acking happens as needed", when you're not acking the messages when you're done consuming them (which is when it's needed)? Clearly you're not acking as needed. Have all consumers ack messages when they're done consuming them, and tell us if you still think you have a problem

Re: Issue with MessageConsumer and MessageSelector

2015-12-15 Thread dabayev
Tim, I am currently playing in my dev environment. I have one consumer which is event driven implementing MessageListener. This consumer is a client_ack consumer and during my development I have not yet acked anything to not remove the messages. My Listener does not at this point, just shows that

Re: Issue with MessageConsumer and MessageSelector

2015-12-15 Thread Tim Bain
Please define concretely "Acking happens as needed." I strongly suspect based on what you've written that you're wrong and acking is in fact not happening as it needs to. Do you understand how round-robin dispatch works for a queue with your two consumers? Do you understand what a consumer's pre

Re: Issue with MessageConsumer and MessageSelector

2015-12-14 Thread dabayev
Acking happens as needed. my page size is set to I have 923 messages on the queue. Any other ideas? -- View this message in context: http://activemq.2283324.n4.nabble.com/Issue-with-MessageConsumer-and-MessageSelector-tp4704870p4704939.html Sent from the ActiveMQ - User mailing list archive

Re: Issue with MessageConsumer and MessageSelector

2015-12-14 Thread artnaseef
Two things to look at. As mentioned above, not ack'ing is one of them. If the session is setup to auto-ack, then that's not the issue. If the session is set to client-ack or transacted, then it needs to ack the messages or the queue will eventually fill up. Another possibility - look at the que

Re: Issue with MessageConsumer and MessageSelector

2015-12-14 Thread dabayev
Also, I am not acking the messages as they come through. Here is what I also notice. I bring up a MessageListener(no ack) and then bring it down. Now I look for my message on the Queue an I find it, copy it into a new message and queue it. I remove the old message. I now try to do the same thing

Re: Issue with MessageConsumer and MessageSelector

2015-12-11 Thread dabayev
I wrote a utility that take a message off the queue based on JMSMessageId, copy its contents but update its header information. That is why i look up by JMSMessageId only to ensure uniqueness. After further investigation, I realized that my problem happens only when I stop my Jboss. My Jboss insta

Re: Issue with MessageConsumer and MessageSelector

2015-12-10 Thread Tim Bain
Are you acknowledging your messages as you finish consuming them? Also, what's the reason you're using a selector on the JMSMessageId? Can you describe what messages you "can find" (and what "find" means) and which ones you can't, as well as where? Tim On Dec 10, 2015 4:06 PM, "dabayev" wrote: