@Test
public void testQueueIsEmptyAfterCreation() throws Exception {

  queue = new FlumeEventQueue(backingStore,
                              backingStoreSupplier.getInflightTakes(),
                              backingStoreSupplier.getInflightPuts(),
                              backingStoreSupplier.getQueueSetDir());
  Assert.assertNull(queue.removeHead(0L));
}