Module: WresqueWrapper::ClassMethods
- Defined in:
- lib/wresque_wrapper.rb
Instance Method Summary collapse
- #default_queue ⇒ Object
- #default_queue=(queue) ⇒ Object
- #default_worker_queue(queue) ⇒ Object
- #delay(opts = {}) ⇒ Object
- #perform(id, method, *args) ⇒ Object
- #queue ⇒ Object
- #queue=(queue) ⇒ Object
Instance Method Details
#default_queue ⇒ Object
11 |
# File 'lib/wresque_wrapper.rb', line 11 def default_queue; @default_queue; end |
#default_queue=(queue) ⇒ Object
12 |
# File 'lib/wresque_wrapper.rb', line 12 def default_queue=(queue); @default_queue = queue; end |
#default_worker_queue(queue) ⇒ Object
14 15 16 |
# File 'lib/wresque_wrapper.rb', line 14 def default_worker_queue(queue) @default_queue = queue end |
#delay(opts = {}) ⇒ Object
27 28 29 |
# File 'lib/wresque_wrapper.rb', line 27 def delay(opts={}) WresqueWrapper::WrapperProxies::Proxy.new(self,self,nil,opts[:queue]) end |
#perform(id, method, *args) ⇒ Object
18 19 20 21 22 23 24 25 |
# File 'lib/wresque_wrapper.rb', line 18 def perform(id, method, *args) ActiveRecord::Base.verify_active_connections! if id self.find(id).send(method, *args) else self.send(method, *args) end end |
#queue ⇒ Object
8 |
# File 'lib/wresque_wrapper.rb', line 8 def queue; @queue; end |
#queue=(queue) ⇒ Object
9 |
# File 'lib/wresque_wrapper.rb', line 9 def queue=(queue); @queue = queue; end |