@Override
            public boolean done() {
              int sz = regionQueue.size();
              cache.getLogger().fine("regionQueue.size()::" + sz);
              return sz == 0 || !proxy.isConnected();
            }
This is to test the serialization mechanism of ClientUpdateMessage. Added after CQ support.
This could be done in different way, by overflowing the HARegion queue.
geode-cq/src/distributedTest/java/org/apache/geode/internal/cache/ha/HADispatcherDistributedTest.java