updated to use one amqp connection