@Override
      public void run2() throws CacheException {
        synchronized (dummyObj) {
          while (waitFlag) {
            try {
              dummyObj.wait();
            } catch (InterruptedException e) {
              fail("interrupted");
            }
          }
        }

        if (waitFlag) {
          fail("test failed");
        }
      }
This is the Dunit test to verify the duplicates after the fail over The test perorms following
operations 1. Create 2 servers and 1 client 2. Perform put operations for knows set of keys
directy from the server1. 3. Stop the server1 so that fail over happens 4. Validate the
duplicates received by the client1
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/ha/HADuplicateDUnitTest.java