@Test
  public void testExpiryPeriod() throws Exception {
    vm0.invoke(() -> HAExpiryDUnitTest.createRegionQueue(Boolean.FALSE));
    vm1.invoke(() -> HAExpiryDUnitTest.createRegionQueue(Boolean.FALSE));
    vm2.invoke(() -> HAExpiryDUnitTest.createRegionQueue(Boolean.FALSE));
    vm3.invoke(() -> HAExpiryDUnitTest.createRegionQueue(Boolean.FALSE));

    vm0.invoke(new CacheSerializableRunnable("putFromVm") {

      @Override
      public void run2() throws CacheException {
        Region region = cache.getRegion(SEPARATOR + REGION_NAME);
        region.put("KEY1", "VALUE1");
      }
    });

    vm0.invoke(HAExpiryDUnitTest::checkSizeBeforeExpiration);
    vm1.invoke(HAExpiryDUnitTest::checkSizeBeforeExpiration);
    vm2.invoke(HAExpiryDUnitTest::checkSizeBeforeExpiration);
    vm3.invoke(HAExpiryDUnitTest::checkSizeBeforeExpiration);

    // Thread.sleep(7 * 1000);

    vm0.invoke(HAExpiryDUnitTest::checkSizeAfterExpiration);
    vm1.invoke(HAExpiryDUnitTest::checkSizeAfterExpiration);
    vm2.invoke(HAExpiryDUnitTest::checkSizeAfterExpiration);
    vm3.invoke(HAExpiryDUnitTest::checkSizeAfterExpiration);
  }
This function creates regionqueue on 4 VMs
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/ha/HAExpiryDUnitTest.java