    @Test
    public void testNotifyClientConnected() throws Exception {

        interceptor.notifyClientConnected(MqttMessageBuilders.connect().build());
        interval();
        assertEquals(40, n.get());
    }