require 'mkit/status' module MKIt class AWorker # Must define topics method on subclass def initialize System[:job_manager].register_worker(self, self.topics) end end end