wow-core/me.ahoo.wow.event/AbstractEventFunctionRegistrar

AbstractEventFunctionRegistrar

abstract class AbstractEventFunctionRegistrar(val delegate: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>> = SimpleMessageFunctionRegistrar()) : MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>> , Decorator<MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>>

Inheritors

DomainEventFunctionRegistrar

ProjectionFunctionRegistrar

StatelessSagaFunctionRegistrar

Constructors

AbstractEventFunctionRegistrar

constructor(delegate: 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

abstract 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<*>>)