Hi Matt,
I am having the same issues as you did. My MessageListener receives messages
but ActiveMQ doesn't dequeue them. I use two different session for consuming
and producing messages but I still have these problems.
What exactly did you put into your new thread? Do you mean by singelton
instan
Thanks. I am storing only the payload (it was an ObjectMessage).
I was able to resolve the issue by spawning a new thread to create my
singleton instance. I read the following from
http://docs.oracle.com/javaee/5/api/javax/jms/Session:
Once a connection has been started, any session with one or m
Hi Matt,
Yes message groups would do the job, as they guarantee that only one
consumer is responsible for consuming that group. From the docs, they
provide "guarranteed ordering of the processing of related messages across a
single queue".
I can't speak about your consumer code, but storing the e
Hi Jakub,
Yes, from the queue on the broker. As far as the broker is concerned, it
remains "in-flight" permanently. What's weirder is when I run a standalone
java client to consume the messages, it has no trouble whatsoever. So I
think there's something going on in the client side that's causing m
Hi Matt,
When you say that the message is not being dequeued, do you mean from the
queue on the broker?
The overall scheme itself seems to be pretty complicated; where are the
topic messages coming from?
If you are trying to ensure that messages for a particular id are consumed
in sequence then
