|
|
|
@ -52,6 +52,7 @@ import org.thingsboard.server.service.subscription.TbSubscriptionUtils; |
|
|
|
|
|
|
|
import java.util.Collection; |
|
|
|
import java.util.Optional; |
|
|
|
import java.util.concurrent.ExecutionException; |
|
|
|
|
|
|
|
/** |
|
|
|
* Created by ashvayka on 27.03.18. |
|
|
|
@ -129,6 +130,15 @@ public class DefaultAlarmSubscriptionService extends AbstractSubscriptionService |
|
|
|
return alarmService.findAlarmByIdAsync(tenantId, alarmId); |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public Alarm findAlarmById(TenantId tenantId, AlarmId alarmId) { |
|
|
|
try { |
|
|
|
return alarmService.findAlarmByIdAsync(tenantId, alarmId).get(); |
|
|
|
} catch (InterruptedException | ExecutionException e) { |
|
|
|
throw new RuntimeException(e); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public ListenableFuture<AlarmInfo> findAlarmInfoByIdAsync(TenantId tenantId, AlarmId alarmId) { |
|
|
|
return alarmService.findAlarmInfoByIdAsync(tenantId, alarmId); |
|
|
|
|