code: public void purge() {
          SortedQueue queue = getQueue();
          _eventStore.purge(_writeChannel);
          queue.clear();
          _eventStore.purge(_readChannel);
      }
docs: Implementation of {@link EventStore#purge(String)}.