|
|
|
@ -211,7 +211,7 @@ public class TbDeviceProfileNodeTest { |
|
|
|
|
|
|
|
registerCreateAlarmMock(alarmService.updateAlarm(any()), false); |
|
|
|
|
|
|
|
|
|
|
|
Thread.sleep(1); |
|
|
|
TbMsg msg2 = TbMsg.newMsg(TbMsgType.POST_TELEMETRY_REQUEST, deviceId, TbMsgMetaData.EMPTY, |
|
|
|
TbMsgDataType.JSON, JacksonUtil.toString(data), null, null); |
|
|
|
node.onMsg(ctx, msg2); |
|
|
|
@ -644,7 +644,7 @@ public class TbDeviceProfileNodeTest { |
|
|
|
|
|
|
|
verify(ctx, Mockito.never()).tellNext(theMsg, "Alarm Created"); |
|
|
|
|
|
|
|
Thread.sleep(halfOfAlarmDelay); |
|
|
|
Thread.sleep(halfOfAlarmDelay + 1); |
|
|
|
|
|
|
|
TbMsg msg2 = TbMsg.newMsg(TbMsgType.POST_TELEMETRY_REQUEST, deviceId, TbMsgMetaData.EMPTY, |
|
|
|
TbMsgDataType.JSON, JacksonUtil.toString(data), null, null); |
|
|
|
@ -768,7 +768,7 @@ public class TbDeviceProfileNodeTest { |
|
|
|
|
|
|
|
verify(ctx, Mockito.never()).tellNext(theMsg, "Alarm Created"); |
|
|
|
|
|
|
|
Thread.sleep(halfOfAlarmDelay); |
|
|
|
Thread.sleep(halfOfAlarmDelay + 1); |
|
|
|
|
|
|
|
TbMsg msg2 = TbMsg.newMsg(TbMsgType.POST_TELEMETRY_REQUEST, deviceId, TbMsgMetaData.EMPTY, |
|
|
|
TbMsgDataType.JSON, JacksonUtil.toString(data), null, null); |
|
|
|
@ -1089,7 +1089,7 @@ public class TbDeviceProfileNodeTest { |
|
|
|
|
|
|
|
verify(ctx, Mockito.never()).tellNext(theMsg, "Alarm Created"); |
|
|
|
|
|
|
|
Thread.sleep(halfOfAlarmDelay); |
|
|
|
Thread.sleep(halfOfAlarmDelay + 1); |
|
|
|
|
|
|
|
TbMsg msg2 = TbMsg.newMsg(TbMsgType.POST_TELEMETRY_REQUEST, deviceId, TbMsgMetaData.EMPTY, |
|
|
|
TbMsgDataType.JSON, JacksonUtil.toString(data), null, null); |
|
|
|
|