Added Runnable and Thread to connect to RabbitMQ broker