broker/ru.sydis.broker.implementations.streams/FlowMessageStream

FlowMessageStream

class FlowMessageStream<K, V>

Constructors

FlowMessageStream

constructor()

Functions

registerProcessor

fun registerProcessor(factory: () -> FlowProcessor<K, V>)

registerSinkProcessor

fun registerSinkProcessor(processor: Processor<K, V>)

registerSourceProcessor

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

fun start(): Job