@Override
        public void beforeSendMessage(ClusterDistributionManager dm, DistributionMessage message) {
          if (message instanceof ManageBucketMessage.ManageBucketReplyMessage) {
            Cache cache = getCache();
            disconnectFromDS();
            await().until(cache::isClosed);
            CRASHED.set(true);
          }
        }
RegressionTest for bug 41336

<p>
TRAC #41336: Unexpected PartitionOfflineException
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/PersistentPartitionedRegionRegressionTest.java