@Override
    public void execute(FunctionContext context) {
      RegionFunctionContext regionFunctionContext = (RegionFunctionContext) context;
      final InternalDistributedMember myId =
          InternalDistributedSystem.getAnyInstance().getDistributedMember();
      // Move all buckets to the destination
      if (myId.equals(source)) {
        PartitionRegionHelper.moveData(regionFunctionContext.getDataSet(), source, destination,
            100);
      }
      pause(1000);
      context.getResultSender().lastResult(myId);
    }
A function which will close the cache if the given source matches the source executing this
function
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/execute/FunctionServiceClientAccessorPRBase.java