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