wow-core/me.ahoo.wow.projection/DefaultProjectionHandler

DefaultProjectionHandler

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

Default implementation of ProjectionHandler 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

DefaultProjectionHandler

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

Functions

handle

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

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

metrizable

fun ProjectionHandler.metrizable(): ProjectionHandler

Wraps a ProjectionHandler with metrics collection capabilities. Returns a MetricProjectionHandler that collects metrics on projection handling operations.