private static void waitForEventsRemovedByQueueRemovalMessage(String durableClientId) {
    CacheClientNotifier ccn = CacheClientNotifier.getInstance();
    CacheClientProxy ccp = ccn.getClientProxy(durableClientId);
    HARegionQueue haRegionQueue = ccp.getHARegionQueue();
    HARegionQueueStats haRegionQueueStats = haRegionQueue.getStatistics();
    await()
        .untilAsserted(
            () -> assertThat(haRegionQueueStats.getEventsRemovedByQrm()).describedAs(
                "Expected queue removal messages: " + 2 + " but actual messages: "
                    + haRegionQueueStats.getEventsRemovedByQrm())
                .isEqualTo(2));
  }
Test that starting a durable client on multiple servers is processed correctly.
geode-cq/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/DurableClientSimpleDUnitTest.java