changed amqp provider and reworked code for queue to include connection task at startup