public static void waitForAsyncEventQueueSize(String senderId, int numQueueEntries,
      boolean localSize) {
    await()
        .untilAsserted(() -> checkAsyncEventQueueSize(senderId, numQueueEntries, localSize));
  }
@deprecated Please use {@link DistributedRule} and Geode User APIs or {@link ClusterStartupRule}
            instead.
geode-dunit/src/main/java/org/apache/geode/internal/cache/wan/AsyncEventQueueTestBase.java