Thank you for your reply @marc.dipasquale > . Honestly, I didn’t understand what you meant with
Instead it looks like you might have some other code in the app that is using the qpid amqp jms library to consume the messages?
This is the code for the consumer
And this is for the code for the publisher
We are using a beam pipeline to process the messages.
PS: This is code is for the integration test.