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

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

    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();

    verifyExpiry();

    assertThat(proxy.verifyIfDuplicate(eventID))
        .describedAs(" eventID should not be duplicate as it is a new entry")
        .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