Kompenzacija poteka dela

Kompenzacija omogoča, da dokončanemu koraku poteka dela dodate obravnavalnik za povrnitev sprememb. Queuety shrani posnetek javnega stanja, ko se ta korak konča, nato pa ob preklicu poteka dela ali po želji ob njegovem neuspehu zažene kompenzacijske obravnavalnike v obratnem vrstnem redu.

Metoda compensate_with()

Pokličite compensate_with() takoj za korakom, katerega učinke naj razveljavi:

use Queuety\Queuety;

Queuety::workflow( 'provision_account' )
    ->then( CreateRemoteUserStep::class )
    ->compensate_with( DeleteRemoteUserCompensation::class )
    ->then( CreateSubscriptionStep::class )
    ->compensate_with( CancelSubscriptionCompensation::class )
    ->then( SendWelcomeEmailStep::class )
    ->dispatch( [ 'user_id' => 42 ] );

Če je potek dela pozneje preklican, se zažene Queuety:

1. CancelSubscriptionCompensation
2. DeleteRemoteUserCompensation

Kompenzacijski obravnavalniki

Kompenzacijski obravnavalniki implementirajo Contracts\Compensation:

use Queuety\Contracts\Compensation;

final class DeleteRemoteUserCompensation implements Compensation {
    public function handle( array $state ): void {
        remote_api_delete_user( $state['remote_user_id'] );
    }
}

Obravnavalnik prejme javno stanje poteka dela, kakršno je bilo takoj po dokončanju kompenziranega koraka. Rezervirani notranji ključi niso vključeni.

Preklic in neuspeh

Ob izrecnem preklicu se kompenzacije dokončanih korakov vedno izvedejo pred izbirnim obravnavalnikom on_cancel().

Ob neuspehu se kompenzacije izvedejo samo, če to izberete:

Queuety::workflow( 'provision_account' )
    ->then( CreateRemoteUserStep::class )
    ->compensate_with( DeleteRemoteUserCompensation::class )
    ->then( CreateSubscriptionStep::class )
    ->compensate_with( CancelSubscriptionCompensation::class )
    ->then( ChargeCardStep::class )
    ->compensate_on_failure()
    ->dispatch( $payload );

Brez compensate_on_failure() neuspešen potek dela ohrani zgodovino dokončanih korakov in ga je mogoče ponoviti od neuspešnega koraka.

Z compensate_on_failure() se kompenzacije dokončanih korakov izvedejo, ko je potek dela označen kot neuspešen. Nato retry_workflow() sproži izjemo, ker je bil potek dela že kompenziran.

Podprte vrste korakov

Kompenzacijo je mogoče dodati za:

• zaporedne korake then()
• skupine parallel()
• korake for_each()
• korake run_workflow()
• zakasnitvene korake delay()
• signalne korake wait_for_signal()
• korake odvisnosti poteka dela wait_for_workflow()

Pri run_workflow() in for_each() se posnetek za kompenzacijo zabeleži, ko se gnezdeno ali razvejano delo v celoti zaključi.

on_cancel() ali kompenzacija

Za razveljavitev stranskih učinkov dokončanih korakov v obratnem vrstnem redu uporabite compensate_with().

Za en postopek čiščenja na ravni poteka dela, ki naj se izvede ob vsakem izrecnem preklicu, uporabite on_cancel().