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

DefaultStatelessSagaHandler

class DefaultStatelessSagaHandler(chain: FilterChain<DomainEventExchange<*>>, errorHandler: ErrorHandler<DomainEventExchange<*>> = LogResumeErrorHandler()) : AbstractHandler<DomainEventExchange<*>> , StatelessSagaHandler

Default implementation of StatelessSagaHandler that uses a filter chain for processing. This handler applies a series of filters to domain event exchanges and handles errors gracefully.

Parameters

chain

The filter chain to apply to domain event exchanges.

errorHandler

The error handler for processing failures (default: LogResumeErrorHandler).

Constructors

DefaultStatelessSagaHandler

constructor(chain: FilterChain<DomainEventExchange<*>>, errorHandler: ErrorHandler<DomainEventExchange<*>> = LogResumeErrorHandler())

Functions

handle

open override fun handle(context: DomainEventExchange<*>): Mono<Void>

执行处理逻辑的方法，当发生异常时使用错误处理器进行处理

metrizable

fun StatelessSagaHandler.metrizable(): StatelessSagaHandler

Wraps a StatelessSagaHandler with metrics collection capabilities. Returns a MetricStatelessSagaHandler that collects metrics on saga handling operations.