wow-kafka/me.ahoo.wow.kafka/KafkaServerCommandExchange

KafkaServerCommandExchange

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

Constructors

Link copied to clipboard
constructor(message: CommandMessage<C>, receiverOffset: ReceiverOffset, attributes: MutableMap<String, Any> = ConcurrentHashMap())

Properties

Link copied to clipboard
open override val attributes: MutableMap<String, Any>
Link copied to clipboard
open override val message: CommandMessage<C>

Functions

Link copied to clipboard
open override fun acknowledge(): Mono<Void>
Generated by Dokka
© 2026 Copyright