re-use amqp connection
better connection error handling