@Test
public void testNotifyTopicPublished() throws Exception {

    interceptor.notifyTopicPublished(
            MqttMessageBuilders.publish().qos(MqttQoS.AT_MOST_ONCE)
                .payload(Unpooled.copiedBuffer("Hello".getBytes())).build(),
            "cli1234",
            "cli1234");
    interval();
    assertEquals(60, n.get());
}