@Override
  public List peek(int batchSize) throws InterruptedException {
    return peek(batchSize, -1);
  }
Removes the events that were peeked by this thread. The events are destroyed from the queue and
conflation map and DispatchedAndCurrentEvents are updated accordingly.
geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java