alerts/ru.sydis.alerts.queue/MessageQueueSizeDecorator

MessageQueueSizeDecorator

class MessageQueueSizeDecorator(baseQueue: IMessageQueue, maxQueueSize: Int) : IMessageQueue

Parameters

baseQueue

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

maxQueueSize

  • максимальное количество хранимых сообщений

Constructors

Link copied to clipboard
constructor(baseQueue: IMessageQueue, maxQueueSize: Int)

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>)