Contents

module Resque
  module Plugins
    module DynamicQueues
      module Attributes

        def get_dynamic_queue(key)
          redis.lrange("dynamic_queue:#{key}", 0, -1)
        end

        def set_dynamic_queue(key, values)
          k = "dynamic_queue:#{key}"
          redis.del(k)
          Array(values).each do |v|
             redis.rpush(k, v)
          end
        end

      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
resque-dynamic-queues-0.5.1	lib/resque/plugins/dynamic_queues/attributes.rb
resque-dynamic-queues-0.5.0	lib/resque/plugins/dynamic_queues/attributes.rb