@Override
          public void run2() throws CacheException {
            toCnt = false;
            if (createBlockingQueue) {
              try {
                for (int i = 0; i < 100; ++i) {
                  hrq.put(new ConflatableObject("1", "1", new EventID(new byte[] {1}, 100, i),
                      false, SEPARATOR + "x"));
                }
              } catch (Exception e) {
                throw new AssertionError(e);
              }
            }

          }
Tests the Blokcing HARegionQueue by doing concurrent put /remove / take / peek , batch peek
operations in multiple regions. The test will have take/remove occuring in all the VMs. This
test is targetted to test for hang or exceptions in blocking queue.
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/ha/HARegionQueueDUnitTest.java