broker/ru.sydis.broker.implementations.streams/BaseMessageStream

BaseMessageStream

class BaseMessageStream<K, V>

Реализация топологии конвеера обработчиков

Parameters

K

класс ключа

V

класс значения

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
fun registerProcessor(factory: () -> Processor<K, V>)

Компоновка pipeline обработки

Link copied to clipboard
fun registerSinkProcessor(processor: Processor<K, V>)

Регистрация процессора синхронизатора сообщений

Link copied to clipboard
fun registerSourceProcessor(processor: SourceProcessor<K, V>)

Регистрация процессора источника сообщений.

Link copied to clipboard
fun start()

Запуск процесса обработки