Sha256: dd6e4ac77c5151ac05c6ce29ad721292b221dc16d1a1595b7ca8b35efe50f692
Contents?: true
Size: 1.31 KB
Versions: 1
Compression:
Stored size: 1.31 KB
Contents
require 'json' module ModernTimes module Base class Worker attr_accessor :index, :supervisor, :thread def self.supervisor(klass, options={}) # self.class_eval do # define_method :create_supervisor do |manager| # puts "calling create_supervisor for klass-#{klass.name} and self=#{self} and manager=#{manager}" # klass.new(manager, self, options) # end # end # TODO: This is nasty but I'm not sure how to create a dynamic class method within a scope eval <<-EOS def self.create_supervisor(manager, worker_options) #{klass.name}.new(manager, self, #{options.to_json}, worker_options) end EOS end # Default supervisor is Base::Supervisor supervisor Supervisor def initialize(opts={}) end # One time initialization prior to first thread def setup end def start raise "Need to override start method in #{self.class.name}" end def stop raise "Need to override stop method in #{self.class.name}" end def status raise "Need to override status method in #{self.class.name}" end def self.default_name name = self.name.sub(/Worker$/, '') name.sub(/::/, '_') end end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
modern_times-0.1.2 | lib/modern_times/base/worker.rb |