@Test
  public void testQueuePutWithConflation() throws Exception {
    haRegionQueue = createHARegionQueue(testName.getMethodName());
    int putPerProducer = 20;
    createAndRunProducers(true, false, true, putPerProducer);
    assertThat(haRegionQueue.size(), is(putPerProducer));
  }
This test does the following :<br>
1)Create producer threads to add objects to queue <br>
2)Start all the producers,all of them will do puts against same set of keys <br>
3)Wait till all put-threads complete their job <br>
4)verify that the size of the queue is equal to the total number of puts done by one thread (as
rest of them will conflate)
geode-core/src/integrationTest/java/org/apache/geode/internal/cache/ha/HARegionQueueJUnitTest.java