Implement rabbit queues and subscriptions