I am using NuGet to work with ActiveMQ https://activemq.apache.org/components/nms/
Also tried Apache.NMS.ActiveMQ.NetStd.
The situation is such that the listener successfully connects to the broker and in the web console this can be seen in the corresponding queue. But messages from the queue don’t consume. Without any errors.
Something like this:
Consumer code. This is AspNet HostedService:
Connected with tcp://...:
Creating connection and session:
I don’t get any exceptions, nothing at all. No messages are delivered to the listener. What could be the problem?
Answers:
Thank you for visiting the Q&A section on Magenaut. Please note that all the answers may not help you solve the issue immediately. So please treat them as advisements. If you found the post helpful (or not), leave a comment & I’ll get back to you as soon as possible.
Method 1
The problem was in the queuePrefetch, the asynchronous consumer does not work with the value 0, in this case, you can use only the synchronous consumer or increase the value of queuePrefetсh.
All methods was sourced from stackoverflow.com or stackexchange.com, is licensed under cc by-sa 2.5, cc by-sa 3.0 and cc by-sa 4.0