wow-kafka/me.ahoo.wow.kafka

Package-level declarations

Types

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>

class KafkaCommandBus(topicConverter: CommandTopicConverter = DefaultCommandTopicConverter(), senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer = NoOpReceiverOptionsCustomizer) : AbstractKafkaBus<CommandMessage<*>, ServerCommandExchange<*>> , DistributedCommandBus

class KafkaDomainEventBus(topicConverter: EventStreamTopicConverter = DefaultEventStreamTopicConverter(), senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer = NoOpReceiverOptionsCustomizer) : AbstractKafkaBus<DomainEventStream, EventStreamExchange> , DistributedDomainEventBus

data class KafkaEventStreamExchange(val message: DomainEventStream, receiverOffset: ReceiverOffset, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : EventStreamExchange

class KafkaServerCommandExchange<C : Any>(val message: CommandMessage<C>, receiverOffset: ReceiverOffset, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : ServerCommandExchange<C>

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

class KafkaStateEventExchange<S : Any>(val message: StateEvent<S>, receiverOffset: ReceiverOffset, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : StateEventExchange<S>