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

registerSourceProcessor

fun registerSourceProcessor(processor: SourceProcessor<K, V>)

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

Parameters

processor

Наследник интерфейса SourceProcessor<K,V>