Thanks for the project. I was able to reproduce the problem and identify
the root cause of the message accumulation. In short, your application is
not acknowledging the messages it receives when invoking
ClientRequestor.request().
When using the core protocol messages must always be explicitly
ack
Justin,
Link to sample project:
https://drive.google.com/file/d/1--vMXNJ3NIUVlRQ9liaMwa-VN3X5uEOE/view?usp=sharing
Any of the three amqUtils.* calls in the main() loop will induce the leakage.
I have not figured out where the second queue in our production comes from, but
that isn’t critical
Hi Endre-
Pro-tip— using message priority falls down at scale like your 10k use case
(using any broker product). ActiveMQ provides a really great feature to help
you with this— a Composite Queue virtual destination with broker-side
filtering.
Producer sends to queue://data.input
Consumer 1 fr
> Is ClientRequestor cheap to make each time?
It's relatively cheap, but of course just about anything can be done enough
to become expensive over time. Also, a ClientRequestor is not thread-safe
so a single instance may be a bottleneck in your application. I don't know
what your performance requi
We do keep a singleton ClientRequestor around forever. Perhaps this is just
wrong? Is ClientRequestor cheap to make each time?
One of my colleagues found that occasionally closing and re-creating the
ClientRequestor avoids this problem, but I’d like to know why.
I think you can see that image
> I don’t know if that image comes through the mailing list...
I can't see your image. For what it's worth, attachments don't usually make
it through the list.
Could you upload the image to another location and provide a link?
Also, could you provide the full stack-trace of the NPE?
I don't see
Greetings!
We are using the Artemis queue-based management APIs, and noticed that one of
the two management queues that appears in the console starts to grow without
bound:
[cid:image003.png@01D9298D.231470D0]
I don’t know if that image comes through the mailing list, but it shows two of
the