class EdgycircleToolBox::CQRS::MessageBus

Public Class Methods

publish(event) click to toggle source
# File lib/edgycircle_toolbox/cqrs/message_bus.rb, line 17
def self.publish(event)
  resolve(event.class).each { |callable| callable.call(event) }
end
subscribe(events, callable) click to toggle source
# File lib/edgycircle_toolbox/cqrs/message_bus.rb, line 13
def self.subscribe(events, callable)
  events.each { |event| register(event, callable) }
end