AbstractKafkaBus

abstract class AbstractKafkaBus<M : Message<*, *>, AggregateIdCapable, NamedAggregate, E : MessageExchange<*, M>>(topicConverter: AggregateTopicConverter, senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer = NoOpReceiverOptionsCustomizer) : DistributedMessageBus<M, E>

Constructors

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

open override fun close()

open override fun receive(namedAggregates: Set<NamedAggregate>): Flux<E>

open override fun send(message: M): Mono<Void>

abstract fun M.toExchange(receiverOffset: ReceiverOffset): E