@Test
  public void cleanCloseOfThreadIdToSeqId() 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);
    proxy = (PoolImpl) poolFactory.create("clientPool");

    EventID eventID1 = new EventID(new byte[0], 1, 2);

    assertThat(proxy.verifyIfDuplicate(eventID1))
        .describedAs("eventID1 can never be duplicate, it is being created for the first time!")
        .isFalse();

    EventID eventID2 = new EventID(new byte[0], 1, 3);
    assertThat(proxy.verifyIfDuplicate(eventID2))
        .describedAs("eventID2 can never be duplicate, since sequenceId is greater ")
        .isFalse();

    assertThat(proxy.verifyIfDuplicate(eventID2))
        .describedAs("eventID2 had to be a duplicate, since sequenceId is equal ")
        .isTrue();

    EventID eventID3 = new EventID(new byte[0], 1, 1);
    assertThat(proxy.verifyIfDuplicate(eventID3))
        .describedAs("eventId3 had to be a duplicate, since sequenceId is lesser")
        .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