class EventSourcing::Event::Bus

Public Class Methods

new(event_store) click to toggle source
# File lib/event_sourcing/event/bus.rb, line 10
def initialize(event_store)
  @store = event_store
  @publisher = Publisher.spawn!(name: :event_publisher, supervise: true)
end

Public Instance Methods

default_reference_class() click to toggle source
# File lib/event_sourcing/event/bus.rb, line 24
def default_reference_class
  Reference
end
on_message(message) click to toggle source
# File lib/event_sourcing/event/bus.rb, line 15
def on_message(message)
  case message
  when :get_event_publisher
    @publisher
  when :get_event_store
    @store
  end
end