wow-kafka/me.ahoo.wow.kafka/KafkaStateEventBus

KafkaStateEventBus

class KafkaStateEventBus(topicConverter: StateEventTopicConverter = DefaultStateEventTopicConverter(), senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer = NoOpReceiverOptionsCustomizer) : DistributedStateEventBus, AbstractKafkaBus<StateEvent<*>, StateEventExchange<*>>

Constructors

KafkaStateEventBus

constructor(topicConverter: StateEventTopicConverter = DefaultStateEventTopicConverter(), senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer = NoOpReceiverOptionsCustomizer)

Properties

open override val messageType: Class<StateEvent<*>>

open override val topicKind: TopicKind

Functions

open override fun close()

open fun receive(namedAggregates: Set<NamedAggregate>): Flux<StateEventExchange<*>>

open fun send(message: StateEvent<*>): Mono<Void>

open override fun StateEvent<*>.toExchange(receiverOffset: ReceiverOffset): StateEventExchange<*>