Class: Temporal::Saga::Saga

Inherits:

Object

• Object
• Temporal::Saga::Saga

Defined in:

lib/temporal/saga/saga.rb

Instance Method Summary

• #add_compensation(activity, *args) ⇒ Object
• #compensate ⇒ Object
• #initialize(context) ⇒ Saga constructor

  A new instance of Saga.

Constructor Details

#initialize(context) ⇒ Saga

Returns a new instance of Saga.

# File 'lib/temporal/saga/saga.rb', line 4

def initialize(context)
  @context = context
  @compensations = []
end

Instance Method Details

#add_compensation(activity, *args) ⇒ Object

# File 'lib/temporal/saga/saga.rb', line 9

def add_compensation(activity, *args)
  compensations << [activity, args]
end

#compensate ⇒ Object

# File 'lib/temporal/saga/saga.rb', line 13

def compensate
  compensations.reverse_each do |(activity, args)|
    context.execute_activity!(activity, *args)
  end
end