KafkaStateEventExchange

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

Constructors

constructor(message: StateEvent<S>, receiverOffset: ReceiverOffset, attributes: MutableMap<String, Any> = ConcurrentHashMap())

open override val message: StateEvent<S>

open override fun acknowledge(): Mono<Void>

open override fun clearError()

open fun <T : Any> extractDeclared(type: Class<T>): T?

open fun <T : Any> extractObject(type: Class<T>): T?

open fun <T> getAttribute(key: String): T?

open override fun <R> getCommandResult(key: String): R?

open override fun getError(): Throwable?

open override fun setCommandResult(key: String, value: Any)

open override fun setError(throwable: Throwable)