public static ServerCQ readCq(DataInput in) throws ClassNotFoundException, IOException {
    if (factory == null) {
      throw new IllegalStateException("CqService is not available.");
    } else {
      return factory.readCqQuery(in);
    }
  }
A debug flag used for testing vMotion during CQ registration
geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqServiceProvider.java