1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
module Noah::Agents
class Base
PREFIX = "base://"
NAME = "base-agent"
DEFAULT_CONCURRENCY = 1
NEEDS_TRANSFORM = false
def self.inherited(base)
Noah::Watchers.register_agent(base)
base.send :include, EM::Deferrable
end
def notify(event, message, watch_list)
logger.info("#{self.class.to_s} worker initiated")
worklist = []
watch_list.select{|w| worklist << w[:endpoint] if (w[:endpoint] =~ /^#{self.class::PREFIX}/ && event =~ /^#{w[:pattern]}/) }
if worklist.size >= 1
logger.info("Dispatching message to #{worklist.size} #{self.class.to_s} endpoints")
EM::Iterator.new(worklist, self.class::DEFAULT_CONCURRENCY).each do |ep, iter|
ep, message = transform(ep, message) if self.class::NEEDS_TRANSFORM == true
work!(ep, message)
iter.next
end
logger.info("Dispatched message to #{worklist.size} #{self.class.to_s} endpoints")
else
logger.info("No work to do")
end
rescue Exception => e
logger.fatal("Exectution of notify failed with #{e.message}")
end
def logger
Noah::Log.logger.progname = self.class.to_s
Noah::Log.logger
end
end
end