How to write an integration test for service that uses ActiveMQ Artemis

Question

I am looking into automated integration tests for a service that consumes from and produces to Red Hat AMQ 7.5.0. I am aware that you can produce & consume via REST, but this service is part of a pipeline and once data is put on a queue, it is potentially quickly sent to the next step.

Is there a way to view or otherwise verify a message has passed through a queue? I would like to verify that specific messages were sent, or ideally some kind of JSON search would be awesome (i.e, search for messages that have gone through that had certain key/value pairs).

Answer 1

ActiveMQ Artemis (the broker shipped in Red Hat AMQ 7.x) doesn't keep historical data about messages that have already been consumed, and I don't know of any broker which does.

However, you could use the LoggingActiveMQServerPlugin to log details about the message to a file and then search through that file for the information you're looking for.