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 one argument.
      # Return queue name otherwise.
      def queue(*args)
        @queue = args.first unless args.empty?
        (@queue || :default).to_s
      end

      # Set the queue options.
      def options(*args)
        @options = args.first unless args.empty?
        @options || {}
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
qe-0.4.0	lib/qe/worker/class_methods.rb