saga.kt

override fun requestProcess(requestDto: RequestDto) {
    val saga = Saga(options)
    try {
        log.info("Creating request")
        val requestId = requestActivity.create(requestDto)
        saga.addCompensation(requestActivity::cancelCreate, requestId)

        log.info("Creating request($requestId) party")
        val requestPartyId = partyActivity.createParty(requestId, requestDto)
        saga.addCompensation(partyActivity::cancelCreateParty, requestPartyId)

        log.info("Linking party($requestPartyId) to request($requestId)")
        val requestPartyLinkRef = requestLinkActivity.linkParty(requestId, requestPartyId)
        saga.addCompensation(requestLinkActivity::unlinkParty, requestPartyLinkRef)
        
        notifyClient.sendEmail(requestId, requestPartyId)
    } catch (e: ActivityFailure) {
        saga.compensate()
    }
}