@Test
  public void testP2PDeltaPropagationCleanStats() throws Exception {
    int numOfKeys = 50;
    long updates = 50;
    Object[] args =
        new Object[] {Boolean.TRUE, DataPolicy.REPLICATE, Scope.DISTRIBUTED_ACK, Boolean.TRUE};
    vm0.invoke(DeltaPropagationStatsDUnitTest.class, "createServerCache", args);
    vm1.invoke(DeltaPropagationStatsDUnitTest.class, "createServerCache", args);
    vm2.invoke(DeltaPropagationStatsDUnitTest.class, "createServerCache", args);
    // Only delta should get sent to vm1 and vm2
    vm0.invoke(() -> DeltaPropagationStatsDUnitTest.putCleanDelta(numOfKeys,
        updates));
    vm0.invoke(DeltaPropagationStatsDUnitTest::putLastKey);

    vm1.invoke(DeltaPropagationStatsDUnitTest::waitForLastKey);
    vm2.invoke(DeltaPropagationStatsDUnitTest::waitForLastKey);

    vm0.invoke(() -> DeltaPropagationStatsDUnitTest
        .verifyDeltaSenderStats(PEER_TO_PEER, numOfKeys * updates));
    vm1.invoke(() -> DeltaPropagationStatsDUnitTest.verifyDeltaReceiverStats(
        PEER_TO_PEER, numOfKeys * updates, 0L));
    vm2.invoke(() -> DeltaPropagationStatsDUnitTest.verifyDeltaReceiverStats(
        PEER_TO_PEER, numOfKeys * updates, 0L));
  }
No error or resending of delta.
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/DeltaPropagationStatsDUnitTest.java