@Override
          public void run2() throws CacheException {
            for (final Thread opThread : opThreads) {

              if (opThread.isInterrupted()) {
                fail("Test failed because  thread encountered exception");
              }
              ThreadUtils.join(opThread, 30 * 1000);
            }
          }
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