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

SagaCompensationContext

interface SagaCompensationContext<TCommand : Any>(source)

Callback surface that SagaCompensator uses to interact with the saga engine while staying decoupled from it. Hides Kafka outbox and JSON serialization details behind a small, intention-revealing API.

The type parameter TCommand is the service-local, strongly-typed compensation command (typically a Kotlin sealed interface mirroring the Avro tagged union) — keeping the engine free of Map<String, Any?> envelopes and stringly-typed action discriminators.

Inheritors

DefaultSagaCompensationContext

Functions

publishCompensationEvent

abstract fun publishCompensationEvent(sagaId: String, stepId: Long?, command: TCommand)

Publishes a typed compensation command to the service-local compensation topic via the Transactional Outbox.

readStepPayload

abstract fun readStepPayload(payload: String?): Map<String, Any?>

Deserializes the step payload (JSON, written by the saga engine on step recording) into a Map. Returns an empty map when the payload is null/blank. Use it inside SagaCompensator to read the data captured at step-record time and assemble the typed TCommand.