Package-level declarations
Types
Link copied to clipboard
Link copied to clipboard
data class DefaultCommandStream(val domainEventId: String, commands: List<CommandMessage<*>>) : CommandStream, Iterable<CommandMessage<*>>
Link copied to clipboard
class DefaultStatelessSagaHandler(chain: FilterChain<DomainEventExchange<*>>, errorHandler: ErrorHandler<DomainEventExchange<*>> = LogResumeErrorHandler()) : AbstractHandler<DomainEventExchange<*>> , StatelessSagaHandler
Link copied to clipboard
class StatelessSagaDispatcher(val name: String, val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, val domainEventBus: DomainEventBus, val stateEventBus: StateEventBus, val functionRegistrar: StatelessSagaFunctionRegistrar, val eventHandler: StatelessSagaHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("SagaDispatcher")) : AbstractEventDispatcher<Mono<*>>
Link copied to clipboard
class StatelessSagaFunction(val delegate: MessageFunction<Any, DomainEventExchange<*>, Mono<*>>, commandGateway: CommandGateway, commandMessageFactory: CommandMessageFactory) : MessageFunction<Any, DomainEventExchange<*>, Mono<CommandStream>> , Decorator<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>
Link copied to clipboard
Link copied to clipboard
class StatelessSagaFunctionRegistrar(commandGateway: CommandGateway, commandMessageFactory: CommandMessageFactory, actual: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>> = SimpleMessageFunctionRegistrar()) : AbstractEventFunctionRegistrar
Link copied to clipboard