alerts/ru.sydis.alerts/AlertsService

AlertsService

object AlertsService

Properties

Link copied to clipboard
val messagesQueue: IMessageQueue

Очередь сообщений для обработки, сюда вычитываем сразу из брокера, потом обрабатываем

Functions

Link copied to clipboard
fun consumeIntoBufferRealtimeData()

Запустить процесс подписки на изменения значений в реальном времени, полученные значения записываются во внутренний буфер

Link copied to clipboard
fun handleBufferedRealtimeValues()

Обрабатывать изменяющиеся значения в реальном времени

Link copied to clipboard
Link copied to clipboard
fun handleRealtimeAlertsCreation()

Хендлер для прослушивания сообщений в брокере о создании нового обработчика алармов. При получении сообщения о создании, вычитывает данные из конфигурационной БД и создаёт экземпляр

Link copied to clipboard
Link copied to clipboard
fun initAlertHandlers(activeReduPartner: Boolean)

Проинициализировать обработчики алармов из конфигурационной БД

Link copied to clipboard
fun installBroker(props: Map<String, Any>)
fun installBroker(customBroker: MessageBroker<ByteArray, ProtoMessage>)
Link copied to clipboard
fun installLogger(customLogger: Logger)