|
|
|
@ -197,7 +197,8 @@ class DeviceState { |
|
|
|
|
|
|
|
private void processAlarmDeleteNotification(TbContext ctx, TbMsg msg) { |
|
|
|
Alarm alarm = JacksonUtil.fromString(msg.getData(), Alarm.class); |
|
|
|
alarmStates.values().removeIf(alarmState -> alarmState.getCurrentAlarm().getId().equals(alarm.getId())); |
|
|
|
alarmStates.values().removeIf(alarmState -> alarmState.getCurrentAlarm() != null |
|
|
|
&& alarmState.getCurrentAlarm().getId().equals(alarm.getId())); |
|
|
|
ctx.tellSuccess(msg); |
|
|
|
} |
|
|
|
|
|
|
|
|