@Override
  public final void postSetUp() throws Exception {
    final Host host = Host.getHost(0);
    // Server1 VM
    server1 = host.getVM(0);

    // Client 1 VM
    client1 = host.getVM(2);

    int PORT1 = server1
        .invoke(() -> HAConflationDistributedTest.createServerCache(Boolean.FALSE));
    server1.invoke(() -> ConflationDistributedTestHelper.setIsSlowStart());
    server1.invoke(HAConflationDistributedTest::makeDispatcherSlow);
    client1
        .invoke(() -> HAConflationDistributedTest.createClientCache(
            NetworkUtils.getServerHostName(host),
            PORT1, Boolean.TRUE));
  }
This is Targetted conflation Dunit test. 1 Client & 1 Server. Slow down the dispatcher. From the
unit controller VM using separate invoke every time so that different thread context are created
on the server ,test the following 1) Do a create & then update on same key , the client should
receive 2 calabcks. 2) Do create , then update & update. The client should receive 2 callbacks ,
one for create & one for the last update. 3) Do create , then update, update, invalidate. The
client should receive 3 callbacks, one for create one for the last update and one for the
invalidate. 4) Do a create , update , update & destroy. The client should receive 3 callbacks (
craete , conflated update & destroy).
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/ha/HAConflationDistributedTest.java