void checkIsStart() {
        if (!initialized) {
            throw new IllegalStateException("Publisher does not start");
        }
    }
@Test
    void testCheckIsStart() {
        assertThrows(IllegalStateException.class, () -> {
            publisher.shutdown();
            publisher = new DefaultPublisher();
            publisher.checkIsStart();
        });
    }