alerts/ru.sydis.alerts.queue/MessageQueuePeriodicCleanerDecorator

MessageQueuePeriodicCleanerDecorator

class MessageQueuePeriodicCleanerDecorator(baseQueue: IMessageQueue, msgLifetime: Duration, checkPeriod: Duration) : IMessageQueue

Parameters

baseQueue

  • базовый класс для работы очередью сообщений

msgLifetime

  • время жизни сообщения, после которого оно считается устаревшим

checkPeriod

  • периодичность срабатывания сборщика устаревших данных

Constructors

Link copied to clipboard
constructor(baseQueue: IMessageQueue, msgLifetime: Duration, checkPeriod: Duration)

Functions

Link copied to clipboard
open override fun itemsList(): List<QueueItem>
Link copied to clipboard
open override fun pop(): Pair<ProtoValue, TimeStamp>?
open override fun pop(msgCount: Int): List<Pair<ProtoValue, TimeStamp>>
Link copied to clipboard
open override fun push(fullMessageList: List<Pair<ProtoValue, TimeStamp>>): List<UUID>
open override fun push(fullMessage: ProtoValue, ts: TimeStamp): UUID
Link copied to clipboard
open override fun remove(uuid: UUID)
open override fun remove(uuidList: List<UUID>)