private void createSendersAndReceivers(Integer lnPort, Integer nyPort, boolean conserveSockets) {
    createCacheConserveSocketsInVMs(conserveSockets, nyPort, vm2, vm3);
    createReceiverInVMs(vm2, vm3);

    createCacheConserveSocketsInVMs(conserveSockets, lnPort, vm4, vm5, vm6, vm7);

    vm4.invoke(() -> createSender("ln", 2, true, 100, 10, false, false, null, true));
    vm5.invoke(() -> createSender("ln", 2, true, 100, 10, false, false, null, true));
    vm6.invoke(() -> createSender("ln", 2, true, 100, 10, false, false, null, true));
    vm7.invoke(() -> createSender("ln", 2, true, 100, 10, false, false, null, true));
  }
Put entries in region after gateway sender is stopped. Count number of PQRM messages sent.
geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelGatewaySenderOperationsDistributedTest.java