public static Integer createServer1Cache() throws Exception {
    new HAGIIDistributedTest().createCache(new Properties());
    AttributesFactory factory = new AttributesFactory();
    factory.setScope(Scope.DISTRIBUTED_ACK);
    factory.setDataPolicy(DataPolicy.REPLICATE);
    RegionAttributes attrs = factory.create();
    cache.createRegion(REGION_NAME, attrs);
    int port = getRandomAvailableTCPPort();
    CacheServer server1 = cache.addCacheServer();
    server1.setPort(port);
    server1.setNotifyBySubscription(true);
    server1.start();
    return server1.getPort();
  }
Client is connected to S1 which has a slow dispatcher. Puts are made on S1. Then S2 is started
and made available for the client. After that , S1 's server is stopped. The client fails over to
S2. The client should receive all the puts . These puts have arrived on S2 via GII of HARegion.
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/ha/HAGIIDistributedTest.java