private void verifyClientIds(final DistributedMember serverMember, final int serverPort)
      throws Exception {
    CacheServerMXBean cacheServerMXBean = awaitCacheServerMXBean(serverMember, serverPort);
    await().untilAsserted(() -> assertThat(cacheServerMXBean.getClientIds()).hasSize(2));
    assertThat(cacheServerMXBean.getClientIds()).hasSize(2); // TODO: write better assertions
  }
This is for testing client IDs
geode-core/src/distributedTest/java/org/apache/geode/management/internal/pulse/TestClientIdsDUnitTest.java