Arroyo with QueenMQ

[xmlking]

Need help on how to use queen MQ with arroyo.
I want to run stream data processing pipeline that consume messages from queen topic1 and write messages to queen topic 2

https://smartpricing.github.io/queen/guide/transactions.html