unless defined? $__rq_job__ module RQ #{{{ LIBDIR = File::dirname(File::expand_path(__FILE__)) + File::SEPARATOR unless defined? LIBDIR require LIBDIR + 'util' require LIBDIR + 'qdb' class Job #{{{ module Methods #{{{ def method_missing(meth, *args, &block) #{{{ setpat = %r/=$/o meth = "#{ meth }" setter = meth =~ setpat meth.gsub! setpat, '' if fields.include? "#{ meth }" if setter self.send('[]=', meth, *args, &block) else self.send('[]', meth, *args, &block) end else super end #}}} end #}}} end class << self #{{{ def new(*a, &b) #{{{ t = QDB::tuple kvs = Util::hashify(*a) kvs.each{|k,v| t[k] = v} t.extend Methods t #}}} end #}}} end #}}} end # class Job #}}} end # module RQ $__rq_job__ = __FILE__ end