Repository URL to install this package:
|
Version:
0.2.10 ▾
|
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