Class: Synapse::EventSourcing::SnapshotUnitOfWorkListener
- Inherits:
-
UnitOfWork::UnitOfWorkListener
- Object
- UnitOfWork::UnitOfWorkListener
- Synapse::EventSourcing::SnapshotUnitOfWorkListener
- Defined in:
- lib/synapse/event_sourcing/snapshot/count_stream.rb
Overview
Unit of work listener that is used to trigger snapshots after a unit of work has been cleaned up
Instance Method Summary collapse
- #initialize(type_identifier, aggregate_id, counter, trigger) ⇒ undefined constructor
- #on_cleanup(unit) ⇒ undefined
Methods inherited from UnitOfWork::UnitOfWorkListener
#after_commit, #on_event_registered, #on_prepare_commit, #on_prepare_transaction_commit, #on_rollback, #on_start
Constructor Details
#initialize(type_identifier, aggregate_id, counter, trigger) ⇒ undefined
72 73 74 75 76 77 |
# File 'lib/synapse/event_sourcing/snapshot/count_stream.rb', line 72 def initialize(type_identifier, aggregate_id, counter, trigger) @type_identifier = type_identifier @aggregate_id = aggregate_id @trigger = trigger @counter = counter end |
Instance Method Details
#on_cleanup(unit) ⇒ undefined
81 82 83 |
# File 'lib/synapse/event_sourcing/snapshot/count_stream.rb', line 81 def on_cleanup(unit) @trigger.trigger_snapshot @type_identifier, @aggregate_id, @counter end |