// Last event should be msg1099
        LogNotificationEvent last = events.get(events.size() - 1);
        assertEquals("msg1099", last.getMessage());
    }

    @Test
    public void test_concurrent_offerAndDrain() throws Exception {
        LogNotificationHelper helper = new LogNotificationHelper();
        int numThreads = 8;
        int eventsPerThread = 200;