protected static ClusterDistributionManager getDistributionManager() {
    if (cache == null) {
      String s = "Cache not created yet!";
      throw new IllegalStateException(s);
    }

    InternalDistributedSystem system =
        (InternalDistributedSystem) cache.getDistributedSystem();
    return (ClusterDistributionManager) system.getDistributionManager();
  }
Return the distribution manager associate with the cache

@since GemFire 2.1
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/DistributedCacheTestCase.java