fix amqp connectivity timing issues