@Test
  public void testC2CDeltaPropagationWithCQ() throws Exception {
    initialise(false/* clone */, new String[] {CQs[1]}, true/* CQ */, true/* RI */,
        true/* enable delta */);
    client.invoke(ClientToServerDeltaDUnitTest.class, "createKeys",
        new Object[] {new String[] {KEY1}});
    client.invoke(ClientToServerDeltaDUnitTest.class, "putDeltaForCQ", new Object[] {KEY1,
        1, new Integer[] {1}, new Boolean[] {false, true, false, false}});

    client.invoke(ClientToServerDeltaDUnitTest::putLastKeyWithDelta);

    client2.invoke(ClientToServerDeltaDUnitTest::waitForLastKey);
    client2.invoke(ClientToServerDeltaDUnitTest::verifyDeltaReceived);
  }
This test has client1 connected to server1 and client2 connected to server2. client2 has a CQ
registered on the server2. client1 creates a key on server1 which satisfies the CQ and it then
updates the same key with a value so that it sould not satisfy the CQ. The cloning is set to
false. The test ensures that the client2 gets the update event. This implies that server2
clones the old value prior to applying delta received from server1 and then processes the CQ.
geode-cq/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/ClientToServerDeltaDUnitTest.java