Added AMQPManager using threads