ssl fix for efficient connect sampler

Author: chongyuanyin

mqtt_jmeter/pom.xml

@@ -3,7 +3,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>net.xmeter</groupId>
     <artifactId>mqtt-jmeter</artifactId>
-    <version>2.0.1</version>
+    <version>2.0.2</version>
 
     <properties>
         <jmeter-version>5.0</jmeter-version>

mqtt_jmeter/src/main/java/net/xmeter/samplers/EfficientConnectSampler.java

@@ -16,6 +16,7 @@
 import net.xmeter.samplers.mqtt.MQTTClient;
 import net.xmeter.samplers.mqtt.MQTTConnection;
 import net.xmeter.samplers.mqtt.MQTTQoS;
+import net.xmeter.samplers.mqtt.MQTTSsl;
 
 public class EfficientConnectSampler extends AbstractMQTTSampler {
 
@@ -162,7 +163,11 @@ private MQTTClient createMqttInstance(String clientId) throws Exception {
 		}
 		parameters.setCleanSession(Boolean.parseBoolean(getConnCleanSession()));
 		parameters.setConnectTimeout(Integer.parseInt(getConnTimeout()));
-
+		if (parameters.isSecureProtocol()) {
+			MQTTSsl ssl = MQTT.getInstance(getMqttClientName()).createSsl(this);
+			parameters.setSsl(ssl);
+		}
+		
 		return MQTT.getInstance(getMqttClientName()).createClient(parameters);
 	}