public void doTestInterestListRecovery(int redundancyLevel) {
    createServersAndClients(redundancyLevel);
    vm1.invoke(InterestListFailoverDUnitTest::createEntries);
    vm2.invoke(InterestListFailoverDUnitTest::createEntries);
    vm0.invoke(InterestListFailoverDUnitTest::createEntries);
    Integer primaryPort =
        vm1.invoke(InterestListFailoverDUnitTest::registerInterestList);
    VM primaryVM;
    if (primaryPort == PORT1) {
      primaryVM = vm0;
    } else {
      primaryVM = vm3;
    }
    vm2.invoke(InterestListFailoverDUnitTest::putA);
    // pause(10000);
    vm1.invoke(InterestListFailoverDUnitTest::validateEntriesA);
    primaryVM.invoke(InterestListFailoverDUnitTest::stopServer);
    // pause(10000);
    vm2.invoke(InterestListFailoverDUnitTest::putB);
    // (10000);
    vm1.invoke(InterestListFailoverDUnitTest::validateEntriesB);
  }
one server two clients create Entries in all vms c1 : register (k1,k2,k3,k4,k5) c2 : put (k1 ->
vm2-key-1) and (k6 -> vm2-key-6) c1 : validate (r.getEntry("key-1").getValue() == "vm2-key-1")
(r.getEntry("key-6").getValue() == "key-6") // as it is not registered s1 : stop server s1 :
start server c2 : put (k1 -> vm2-key-1) and (k6 -> vm2-key-6) c1 : validate
(r.getEntry("key-1").getValue() == "vm2-key-1") (r.getEntry("key-6").getValue() == "key-6") //
as it is not registered
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/InterestListFailoverDUnitTest.java