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

StateEventCompensator

class StateEventCompensator(stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, stateEventBus: StateEventBus) : EventCompensator<StateEvent<*>>

Constructors

Link copied to clipboard
constructor(stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, stateEventBus: StateEventBus)

Functions

Link copied to clipboard
open override fun compensate(eventStream: StateEvent<*>, 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>