shared-infrastructure/com.vertyll.veds.sharedinfrastructure.saga.service/SagaCompensationEngine/handleCompensationEvent

handleCompensationEvent

@Transactional

open fun handleCompensationEvent(payload: ByteArray)(source)

Entry point for inbound compensation events.

Deserializes payload via CompensationCommandDeserializer, delegates the domain action to CompensationCommandHandler, and records a Compensate<originalStep> audit row via SagaCompensationStepFactory.

Exceptions are intentionally propagated to the caller so the Kafka listener can trigger broker-level retry / DLT routing. Idempotency is preserved by the inbound ProcessedEventGuard (consumer side) and by the unique-constraint on saga step (sagaId, stepName).