alerts/ru.sydis.alerts.queue/MessageQueueSizeDecorator/push

push

open override fun push(fullMessage: ProtoValue, ts: TimeStamp): UUID

Return

UUID - идентификатор, который был присвоен сообщению в разрезе очереди

Parameters

fullMessage

  • пара - сообщение от брокера, которое необходимо сохранить

ts

  • время формирования пакета от источника

open override fun push(fullMessageList: List<Pair<ProtoValue, TimeStamp>>): List<UUID>

Return

List - список идентификаторов, которые были присвоены сообщениям

Parameters

fullMessageList

  • список пар - сообщения от брокера, которые необходимо сохранить