Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Debian packages RPM packages NuGet packages

Repository URL to install this package:

Details    
rrq / lib / rrq / scripts / pop.rb
Size: Mime:
module Rrq
  module Scripts
    class Pop < Base
      def lua_filename
        "pop.lua"
      end
      
      def request(queue_name)
        queue_name = @conn.redis { |r| r.srandmember(Rrq::Keys.queues) } if queue_name.nil?
        json = @conn.redis { |r| r.evalsha(@sha, [], [queue_name]) }
        JSON.parse(json) if json
      end
    end
  end
end