private void checkCqEvents(int expectedNumberOfEvents) {
    // Check if number of events is correct
    clientSite2DurableSubscription.invoke(() -> await().untilAsserted(() -> assertThat(
        ParallelGatewaySenderAndCQDurableClientDUnitTest.cqListener.getNumEvents())
            .isEqualTo(expectedNumberOfEvents)));
  }
Check that all events are received on durable client that registered cq's
geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelGatewaySenderAndCQDurableClientDUnitTest.java