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