lib/reactor/event.rb in reactor-0.1.0 vs lib/reactor/event.rb in reactor-0.1.1
- old
+ new
@@ -38,9 +38,10 @@
remove_scheduled_job job if job
delay.publish(name, data.except(:was)) if data[:at].future?
end
def self.process(name, data)
+ # fire database listeners
Reactor::Subscriber.where(event: name.to_s).each do |subscriber|
Reactor::Subscriber.delay.fire subscriber.id, data
end
#TODO: support more matching?