wow-core/me.ahoo.wow.saga.stateless/StatelessSagaFunctionRegistrar

StatelessSagaFunctionRegistrar

class StatelessSagaFunctionRegistrar(commandGateway: CommandGateway, commandMessageFactory: CommandMessageFactory, actual: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>> = SimpleMessageFunctionRegistrar()) : AbstractEventFunctionRegistrar

Constructors

StatelessSagaFunctionRegistrar

constructor(commandGateway: CommandGateway, commandMessageFactory: CommandMessageFactory, actual: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>> = SimpleMessageFunctionRegistrar())

Properties

open override val delegate: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>

open override val functions: Set<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>

Functions

open override fun register(function: MessageFunction<Any, DomainEventExchange<*>, Mono<*>>)

registerProcessor

fun registerProcessor(processor: Any)

resolveProcessor

open override fun resolveProcessor(processor: Any): Set<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>

supportedFunctions

open override fun <M : Message<*, Any>, NamedBoundedContext, NamedAggregate> supportedFunctions(message: M): Sequence<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>

open override fun unregister(function: MessageFunction<Any, DomainEventExchange<*>, Mono<*>>)