@Test
  public void testForDuplicateEvents() throws Exception {
    vm0.invoke(HARegionQueueDUnitTest::createRegionQueue);
    vm1.invoke(HARegionQueueDUnitTest::createRegionQueueandCheckDuplicates);
  }
Checks the data received by GII, only gets expired after proper construction of HARegionQueue
object.
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/ha/HARegionQueueDUnitTest.java