Contents

module Rekiq
  module Middleware
    class Utils
      def call(worker, msg, queue)
        if worker.respond_to?(:scheduled_work_time) and
           msg.key?('rq:at')
          worker.scheduled_work_time = Time.at(msg['rq:at']).utc
        end

        yield
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
rekiq-0.9.1	lib/rekiq/middleware/utils.rb
rekiq-0.9.0	lib/rekiq/middleware/utils.rb
rekiq-0.8.1	lib/rekiq/middleware/utils.rb
rekiq-0.7.0	lib/rekiq/middleware/utils.rb
rekiq-0.6.0	lib/rekiq/middleware/utils.rb
rekiq-0.5.0	lib/rekiq/middleware/utils.rb
rekiq-0.0.1	lib/rekiq/middleware/utils.rb