|
|
@ -89,7 +89,7 @@ public class DeviceTypeManagementJMeterTestCase extends TestBase {
|
|
|
|
// Allow some time for message delivery
|
|
|
|
// Allow some time for message delivery
|
|
|
|
Thread.sleep(10000);
|
|
|
|
Thread.sleep(10000);
|
|
|
|
ArrayList<MqttMessage> mqttMessages = mqttDeviceSubscriberClient.getMqttMessages();
|
|
|
|
ArrayList<MqttMessage> mqttMessages = mqttDeviceSubscriberClient.getMqttMessages();
|
|
|
|
Assert.assertEquals("listener did not recieve mqtt messages ", 0, mqttMessages.size());
|
|
|
|
Assert.assertEquals("listener did not recieve mqtt messages ", 1, mqttMessages.size());
|
|
|
|
|
|
|
|
|
|
|
|
String topicPub = automationContext.getContextTenant().getDomain() + "/"+deviceType+"/"+deviceId+"/events";
|
|
|
|
String topicPub = automationContext.getContextTenant().getDomain() + "/"+deviceType+"/"+deviceId+"/events";
|
|
|
|
int qos = 2;
|
|
|
|
int qos = 2;
|
|
|
|