wow-core/me.ahoo.wow.event.compensation/DomainEventCompensator

DomainEventCompensator

class DomainEventCompensator(eventStore: EventStore, eventBus: DomainEventBus) : EventCompensator<DomainEventStream>

Constructors

Link copied to clipboard
constructor(eventStore: EventStore, eventBus: DomainEventBus)

Functions

Link copied to clipboard
open override fun compensate(eventStream: DomainEventStream, target: CompensationTarget): Mono<Void>
open fun compensate(aggregateId: AggregateId, version: Int, target: CompensationTarget): Mono<Long>
Link copied to clipboard
open override fun resend(aggregateId: AggregateId, headVersion: Int, tailVersion: Int, target: CompensationTarget): Mono<Long>