@Override
    public long currentEventSize() {
        return queue.size();
    }
@Test
    void testCurrentEventSize() {
        assertEquals(0, publisher.currentEventSize());
        publisher.publish(new MockEvent());
        assertEquals(1, publisher.currentEventSize());
    }