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

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

    proxy = (PoolImpl) poolFactory.create("clientPool");

    final EventID eventID = new EventID(new byte[0], 1, 1);
    assertThat(proxy.verifyIfDuplicate(eventID))
        .describedAs(" eventID should not be duplicate as it is a new entry")
        .isFalse();

    await().untilAsserted(() -> assertThat(proxy.verifyIfDuplicate(eventID)).isTrue());
  }
Tests the functionality of operations of AbstractConnectionProxy & its derived classes.
geode-core/src/integrationTest/java/org/apache/geode/internal/cache/tier/sockets/ConnectionProxyIntegrationTest.java