Contents

module Creeper
  module Legacy

    module ClassMethods

      def job_descriptions
        @job_descriptions ||= {}
      end

      def enqueue(job, *args)
        enqueue!(job, *args)
      end

      def enqueue!(job, *args)
        options     = args.last.is_a?(Hash) ? args.last : {}
        priority    = options[:priority] || options[:pri] || 65536
        delay       = [ 0, options[:delay].to_i ].max
        time_to_run = options[:time_to_run] || options[:ttr] || 120

        klass = options[:class] || job_descriptions[job]

        Creeper::Client.push({
          'queue'       => job,
          'args'        => args,
          'class'       => klass,
          'delay'       => delay,
          'priority'    => priority,
          'time_to_run' => time_to_run
        })
      end

    end

    module WorkerMethods

      def creeper_legacy_queue(tube = nil)
        return @creeper_legacy_queue if tube.nil?
        (@creeper_legacy_queue = tube).tap do
          Creeper.job_descriptions[@creeper_legacy_queue] = self
        end
      end

    end

  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
creeper-2.0.2	lib/creeper/legacy.rb
creeper-2.0.1	lib/creeper/legacy.rb
creeper-2.0.0	lib/creeper/legacy.rb