Contents

module Qe
  module Worker
    module ClassMethods
      # Enqueue job on given worker class.
      def enqueue(options = {})
        run_at = options.delete(:run_at)

        if run_at
          Qe.adapter.schedule(self, run_at, options)
        else
          Qe.adapter.enqueue(self, options)
        end
      end

      # Set the queue name when receiving on argument.
      # Return queue name otherwise.
      def queue(*args)
        @queue = args.first unless args.empty?
        (@queue || :default).to_s
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
qe-0.3.0	lib/qe/worker/class_methods.rb
qe-0.2.1	lib/qe/worker/class_methods.rb