Module: Resque::Plugins::QueuePriority::Attributes

Defined in:
lib/resque/plugins/queue_priority/attributes.rb

Instance Method Summary collapse

Instance Method Details

#priority_buckets ⇒ Object 



9
10
11
12
13
14
 
# File 'lib/resque/plugins/queue_priority/attributes.rb', line 9

def priority_buckets
  priorities = Array(redis.lrange(PRIORITY_KEY, 0, -1))
  priorities = priorities.collect {|p| Resque.decode(p) }
  priorities << {'pattern' => 'default'} unless priorities.find {|b| b['pattern'] == 'default' }
  return priorities
end

#priority_buckets=(data) ⇒ Object 



16
17
18
19
20
21
22
23
 
# File 'lib/resque/plugins/queue_priority/attributes.rb', line 16

def priority_buckets=(data)
  redis.multi do
    redis.del(PRIORITY_KEY)
    Array(data).each do |v|
       redis.rpush(PRIORITY_KEY, Resque.encode(v))
    end
  end
end