Refactor and adapt rabbitmq queues implementation to new interface.