@Override
      public void run() {
        try {
          takenObjects.add(rq.take());
        } catch (Exception e) {
          testFailed = true;
          message.append("Exception while performing take operation " + e.getStackTrace());
        }
      }
This method performs the following steps :<br>
1)Create a blocking queue and start a thread which does take() on it. 2)Verify after
significant time that the thread is still alive as it should be blocked on take() since there
are no events in the queue.<br>
3)Do a put into the queue and verify that the take thread returns with the same object.

@param conflationEnabled - whether conflation is enabled or not
geode-core/src/integrationTest/java/org/apache/geode/internal/cache/ha/BlockingHARQAddOperationJUnitTest.java