@Override
        public void run() {
          try {
            takenObjects.add(rq.take());
          } catch (Exception e) {
            testFailed = true;
            message.append("Exception while performing take operation " + e.getStackTrace());
          }
        }
This test performs the following steps :<br>
1)Create a blocking queue.<br>
2) Start two threads which does take() on it and add the return object to a list.<br>
3)Put two object into the queue. <br>
4)Verify both both take() threads return with an object by ensuring that the size of the list
containing return objects is two.<br>
geode-core/src/integrationTest/java/org/apache/geode/internal/cache/ha/BlockingHARQAddOperationJUnitTest.java