@Test
public void testNotifyTopicSubscribed() throws Exception {

    interceptor.notifyTopicSubscribed(new Subscription("cli1", new Topic("o2"), MqttQoS.AT_MOST_ONCE), "cli1234");
    interval();
    assertEquals(70, n.get());
}