private void ValidateRegionSizes(int port) {
    await().untilAsserted(() -> {
      Region region = cache.getRegion(SEPARATOR + regionName);
      Region<Object, Object> msgsRegion =
          cache.getRegion(CacheServerImpl.generateNameForClientMsgsRegion(port));
      int clientMsgRegionSize = msgsRegion.size();
      int regionSize = region.size();
      assertThat(((5 == clientMsgRegionSize) && (5 == regionSize))).describedAs(
          "Region sizes were not as expected after 60 seconds elapsed. Actual region size = "
              + regionSize + "Actual client msg region size = " + clientMsgRegionSize)
          .isTrue();
    });
  }
This test verifies that the ha-region-queues increment the reference count of their respective
HAEventWrapper instances in the client-messages-region correctly, during put as well as GII
path.
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/ha/HARQueueNewImplDistributedTest.java