@Override
    public void beforeProcessMessage(ClusterDistributionManager dm, DistributionMessage message) {
      if (message instanceof DestroyPartitionedRegionMessage) {
        startedBlocking.countDown();
      }
    }
Enable persistence for GatewaySender. Pause the sender and do some puts in local region. Stop
GatewaySender.
Then start GatewaySender with clean-queues option. Check if the remote site receives all the
events.
geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java