public static void checkQueueOnSecondary(final Map<String, List<?>> primaryUpdatesMap) {
    final HashMap<String, List<?>> secondaryUpdatesMap = new HashMap<>();
    secondaryUpdatesMap.put("Create", listener1.createList);
    secondaryUpdatesMap.put("Update", listener1.updateList);
    secondaryUpdatesMap.put("Destroy", listener1.destroyList);

    await().untilAsserted(() -> {
      secondaryUpdatesMap.put("Create", listener1.createList);
      secondaryUpdatesMap.put("Update", listener1.updateList);
      secondaryUpdatesMap.put("Destroy", listener1.destroyList);
      assertThat(secondaryUpdatesMap.equals(primaryUpdatesMap)).as(
          "Expected secondary map to be " + primaryUpdatesMap + " but it is " + secondaryUpdatesMap)
          .isEqualTo(true);
    });
  }
Returns a Map that contains the count for number of cache server and number of Receivers.
geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/WANTestBase.java