shared-infrastructure/com.vertyll.veds.sharedinfrastructure.saga.service/SagaCompensator

SagaCompensator

interface SagaCompensator<S : Saga<S>, T : SagaStep<T>, TCommand : Any>(source)

Domain-specific compensation hook used by SagaEngine.

Implementations decide what to do for each step that needs to be undone. Typically, compensation publishes a typed compensation event via SagaCompensationContext.publishCompensationEvent which is then consumed by a service-local Kafka listener.

Works against the persistence-agnostic Saga / SagaStep contracts so it is independent of the underlying storage technology. The type parameter TCommand is the service-local, strongly-typed compensation command — keeping the engine free of stringly-typed dispatch.

Functions

compensateStep

abstract fun compensateStep(saga: S, step: T, context: SagaCompensationContext<TCommand>)

Compensates a single completed step of saga. Implementations typically publish a typed compensation TCommand via SagaCompensationContext.publishCompensationEvent so the local Kafka listener performs the actual undo asynchronously.