Class: RockQueue::ResqueQueue
- Inherits:
-
Object
- Object
- RockQueue::ResqueQueue
- Defined in:
- lib/rock-queue/adapters/resque.rb
Instance Attribute Summary collapse
-
#obj ⇒ Object
readonly
Returns the value of attribute obj.
Instance Method Summary collapse
-
#initialize(options) ⇒ ResqueQueue
constructor
Contructor of Resque adapter.
-
#pop ⇒ Object
Retrieve item from Resque queue.
-
#push(value, args) ⇒ Object
Push item from Resque queue.
Constructor Details
#initialize(options) ⇒ ResqueQueue
Contructor of Resque adapter
14 15 16 |
# File 'lib/rock-queue/adapters/resque.rb', line 14 def initialize() Resque.redis = "#{[:server]}:#{[:port]}" end |
Instance Attribute Details
#obj ⇒ Object (readonly)
Returns the value of attribute obj.
11 12 13 |
# File 'lib/rock-queue/adapters/resque.rb', line 11 def obj @obj end |
Instance Method Details
#pop ⇒ Object
Retrieve item from Resque queue
29 30 31 32 |
# File 'lib/rock-queue/adapters/resque.rb', line 29 def pop job = Resque.reserve :default [job.payload_class, job.args] if job end |
#push(value, args) ⇒ Object
Push item from Resque queue
19 20 21 22 23 24 25 26 |
# File 'lib/rock-queue/adapters/resque.rb', line 19 def push(value, args) if !defined?(value.queue) value.class_eval do @queue = :default end end Resque.enqueue value, args end |