@Test
  public void twoClientsHavingDifferentThreadIdMaps() throws Exception {
    int port3 = getRandomAvailableTCPPort();
    addCacheServer(port3, 10000);

    PoolFactory poolFactory = PoolManager.createFactory();
    poolFactory.addServer("localhost", port3);
    poolFactory.setSubscriptionEnabled(true);
    poolFactory.setSubscriptionRedundancy(-1);
    poolFactory.setSubscriptionMessageTrackingTimeout(100000);

    PoolImpl proxy1 = (PoolImpl) poolFactory.create("clientPool1");
    try {
      PoolImpl proxy2 = (PoolImpl) poolFactory.create("clientPool2");
      try {
        Map map1 = proxy1.getThreadIdToSequenceIdMap();
        Map map2 = proxy2.getThreadIdToSequenceIdMap();
        assertThat(map1 == map2).isFalse();
      } finally {
        proxy2.destroy();
      }
    } finally {
      proxy1.destroy();
    }
  }
Tests the functionality of operations of AbstractConnectionProxy & its derived classes.
geode-core/src/integrationTest/java/org/apache/geode/internal/cache/tier/sockets/ConnectionProxyIntegrationTest.java