Class: Synapse::EventSourcing::SnapshotUnitOfWorkListener

Inherits:
UnitOfWork::UnitOfWorkListener show all
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

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

Parameters:



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

Parameters:

Returns:

  • (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