class God::Trigger
Attributes
triggers[RW]
Public Class Methods
broadcast(task, message, payload)
click to toggle source
# File lib/god/trigger.rb, line 27 def self.broadcast(task, message, payload) return unless self.triggers[task.name] @mutex.synchronize do self.triggers[task.name].each do |t| t.process(message, payload) end end end
deregister(condition)
click to toggle source
# File lib/god/trigger.rb, line 20 def self.deregister(condition) @mutex.synchronize do self.triggers[condition.watch.name].delete(condition) self.triggers.delete(condition.watch.name) if self.triggers[condition.watch.name].empty? end end
register(condition)
click to toggle source
# File lib/god/trigger.rb, line 13 def self.register(condition) @mutex.synchronize do self.triggers[condition.watch.name] ||= [] self.triggers[condition.watch.name] << condition end end
reset()
click to toggle source
# File lib/god/trigger.rb, line 37 def self.reset self.triggers.clear end