public static void validateRegionSize(String regionName, final int regionSize) {
    IgnoredException exp =
        addIgnoredException(ForceReattemptException.class.getName());
    IgnoredException exp1 =
        addIgnoredException(CacheClosedException.class.getName());
    try {
      final Region<?, ?> r = cache.getRegion(SEPARATOR + regionName);
      if (regionSize != r.keySet().size()) {
        await()
            .untilAsserted(() -> assertThat(r.keySet().size()).as(
                "Expected region entries: " + regionSize + " but actual entries: "
                    + r.keySet().size() + " present region keyset " + r.keySet())
                .isEqualTo(regionSize));
      }
    } finally {
      exp.remove();
      exp1.remove();
    }
  }
To be used only for ParallelGatewaySender.

@param senderId Id of the ParallelGatewaySender
geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/WANTestBase.java