@Test
  public void allEventsShouldReachClientWithoutExpiring() throws Exception {
    server.invoke(this::generateEvents);
    client.invoke(this::validateEventCountAtClient);
  }
First generate some events, then wait for some time to let the initial events expire before
the dispatcher sends them to the client. Then do one final put so that the client knows when
to being validation.

<p>
Client is waiting for afterCreate to be invoked number of PUT_COUNT times before proceeding
with validation.

<p>
If the bug exists or is reintroduced, then the events will expire without reaching the client.
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/ha/HARegionQueueExpiryRegressionDistributedTest.java