@Override
    public void beforeProcessMessage(ClusterDistributionManager dm, DistributionMessage message) {
      if (message instanceof RequestImageMessage) {
        RequestImageMessage rim = (RequestImageMessage) message;
        Region region = getCache().getRegion(rim.regionPath);
        if (region instanceof BucketRegion) {
          getCache().close();
        }
      }
    }
This class tests that bucket regions can handle a failure of the GII target during GII.

<p>
TRAC #41091: Missing primary detected after member forcefully disconnected from DS (underlying
InternalGemFireError: Trying to clear a bucket region that was not destroyed)
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/BucketCreationGIIHARegressionTest.java