Switch to using Flux client to use RabbitMQ directly