@Override
          public void run() {
            System.out.println("crashing distributed system");
            GemFireCacheImpl cache = (GemFireCacheImpl) event.getRegion().getCache();
            MembershipManagerHelper.crashDistributedSystem(cache.getDistributedSystem());
          }
CacheListenerTriggeringForcedDisconnect crashes the distributed system when it is invoked for
the first time.
After that it ignores any notifications.
geode-core/src/distributedTest/java/org/apache/geode/cache30/ReconnectDUnitTest.java