@BeforeAll
    public static void before() throws MqttException {
        container.start();

        mqttClient = new MqttAsyncClient(getBrokerUrl(), UUID.randomUUID().toString(), new MemoryPersistence());
        IMqttToken token = mqttClient.connect();
        token.waitForCompletion(WAIT_FOR_COMPLETION);
        subscribe();
    }
@author Younsung Hwang
@author Taejin Koo
agent-module/plugins-it/paho-mqtt-it/src/test/java/com/navercorp/pinpoint/it/plugin/paho/mqtt/PahoMqttV5ClientIT.java