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

    PoolFactory poolFactory = PoolManager.createFactory();
    poolFactory.addServer("localhost", port3);
    poolFactory.setSubscriptionEnabled(true);
    poolFactory.setSubscriptionRedundancy(-1);
    poolFactory.setSubscriptionMessageTrackingTimeout(5000);
    poolFactory.setSubscriptionAckInterval(2000);
    proxy = (PoolImpl) poolFactory.create("clientPool");

    final int EVENT_ID_COUNT = 10000; // why 10,000?
    EventID[] eventIds = new EventID[EVENT_ID_COUNT];
    for (int i = 0; i < EVENT_ID_COUNT; i++) {
      eventIds[i] = new EventID(new byte[0], i, i);
      assertThat(proxy.verifyIfDuplicate(eventIds[i]))
          .describedAs("eventIds can never be duplicate, it is being created for the first time!")
          .isFalse();
    }
    verifyExpiry();

    for (int i = 0; i < EVENT_ID_COUNT; i++) {
      assertThat(proxy.verifyIfDuplicate(eventIds[i]))
          .describedAs(
              "eventIds can not be found to be duplicate since the entry should have expired! " + i)
          .isFalse();
    }
  }
Tests the functionality of operations of AbstractConnectionProxy & its derived classes.
geode-core/src/integrationTest/java/org/apache/geode/internal/cache/tier/sockets/ConnectionProxyIntegrationTest.java