@Override
      public boolean done() {
        if (stats.getAsyncQueues() <= initialQueues) {
          return true;
        }
        getRuntime().gc();
        return false;
      }
Make sure a disconnect causes queue memory to be released.
geode-core/src/distributedTest/java/org/apache/geode/cache30/SlowRecDUnitTest.java