Why the messages remain in the QUEUE after the subscriber consume the message
Hello,
I have a Java Apache Camel consumer that consumes and acknowledge messages from a topic a/b/c/t1 .
I have a Queue subscribed to the same topic (a/b/c/>) .
when I push a message (persistent or non-persistent) to the topic , I m able to consume the message in my java application but the message remain in the queue . What I m missing in my queue configuration to make the message deleted after it is acknowledged by the consumer ? (I don't want to use a TTL)
the service is behaving like if it is only browsing the queue. .
Thank you
Answers
-
Hi Sbelag,
It sounds like you are consuming from the topic instead of the queue. If both your app and the queue subscribe to the same topic they'll both get a copy of the message. I think what you want to do is consume from the queue instead of the topic and then when the app acks, the message will be removed from the queue.
1
