@Override
    public void beforeProcessMessage(ClusterDistributionManager dm, DistributionMessage message) {
      if (message instanceof ManageBucketMessage) {
        vm.invoke(() -> crashDistributedSystem(cacheRule.getSystem()));
      }
    }
A test to make sure that we cannot move a bucket to a member which already hosts the bucket,
thereby reducing our redundancy.
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/BucketCreationCrashCompletesRegressionTest.java