Contents

module Lux::DelayedJob
  module Redis
    extend self

    def que
      @@server ||= Lux.config(:redis_server)
    end

    def push(list)
      que.push Marshal.dump list
    end

    def pop
      que.process(true) do |message|
        Marshal.load(message) rescue nil
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
lux-fw-0.2.3	./lib/lux/delayed_job/lib/redis.rb
lux-fw-0.2.1	./lib/lux/delayed_job/lib/redis.rb
lux-fw-0.1.35	./lib/lux/delayed_job/lib/redis.rb
lux-fw-0.1.17	./lib/lux/delayed_job/lib/redis.rb