@Override
      public void afterProcessMessage(ClusterDistributionManager dm, DistributionMessage message) {
        if (message instanceof AbstractUpdateMessage) {
          DistributionMessageObserver.setInstance(null);
        }
      }
Tests to make sure that after we get a conflicting persistent data exception, we can still
recover.
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/persistence/PersistentRecoveryOrderDUnitTest.java