TransactionEventStore

An extension of https://github.com/arkency/ruby_event_store with support for pessimistic locking and snapshots.

• Mongoid
• Active Record coming soon

Snapshot Aggregate Root an "Aggregate Root" implementation using this event store.

Same as RubyEventStore::Client except the following additions

• publish_snapshot - delegates to repository#create_snapshot
• last_stream_snapshot - delegates to repository#last_stream_snapshot

• with_lock method added, which delegates to repository#with_lock
• notify_susbsribers method added, which exposes the exising event_broker#notify_subscribers function (this is used with_write_context to ensure event handlers aren't called until after the events are committed)

• Event store reader methods (read_events_forward etc), that accept a count: parameter can be passed count: nil to disable limits