Hi guys,
I'm working on this story and I'd like to hear your thoughts.
The Jira: https://issues.apache.org/jira/browse/ARTEMIS-2097
This is to provide a functionality of the broker to block on producers so
that user can consume all the existing messages (for maintaining their
servers for example), regardless of how the address setting's address full
policy is configured. The unblock
functionality should also be provided to complete this feature.
Here is my current implementation:
https://github.com/apache/activemq-artemis/pull/2371
The idea is to keep a list of blocked/unblock addresses set by the user.
Any incoming messages will be checked against the list and if its address
is blocked, it will be rejected and an exception will be thrown to the
clients. It works for all types of clients (core, openwire, jms, mqtt etc).
Any comments are welcome.
Thanks
Howard
|