@Override
        public void run() {
          synchronized (doTestDisconnectCleanup_Listener.CONTROL_LOCK) {
            doTestDisconnectCleanup_Listener.CONTROL_LOCK.notifyAll();
          }
        }
Make sure a disconnect causes queue memory to be released.
geode-core/src/distributedTest/java/org/apache/geode/cache30/SlowRecDUnitTest.java