better AMQP connection management