Class: Sequent::Core::AggregateSnapshotter
Instance Method Summary
collapse
#handle_message, included
new_uuid
Instance Method Details
#take_snapshot!(aggregate_id) ⇒ Object
31
32
33
34
35
36
37
|
# File 'lib/sequent/core/aggregate_snapshotter.rb', line 31
def take_snapshot!(aggregate_id)
aggregate = repository.load_aggregate(aggregate_id)
Sequent.logger.info "Taking snapshot for aggregate #{aggregate}"
aggregate.take_snapshot!
rescue => e
Sequent.logger.error("Failed to take snapshot for aggregate #{aggregate_id}: #{e}, #{e.inspect}")
end
|