Added support for RabbitMQ, still needs more testing.