@Test
  public void testRemoveDuringQuery() {
    doOpDuringBucketRemove((OpDuringBucketRemove) (pr, key, value) -> {
      try {
        SelectResults sr = pr.query("toString()='doOpDuringBucketRemove.VALUE'"); // fetch
                                                                                  // everything
        assertEquals(1, sr.size());
        assertEquals(value, sr.iterator().next());
      } catch (QueryException ex) {
        Assert.fail("didn't expect a QueryException", ex);
      } catch (QueryInvalidException ex2) {
        Assert.fail("didn't expect QueryInvalidException", ex2);
      }
    });
  }
Creates partitioned regions in multiple vms and fully exercises the internal-only
getInternalPRDetails API on ResourceManager.
geode-core/src/distributedTest/java/org/apache/geode/cache/management/ResourceManagerDUnitTest.java