Module: Backburner::Performable::ClassMethods

Defined in:
lib/backburner/performable.rb

Overview

InstanceMethods

Instance Method Summary collapse

Instance Method Details

#async(opts = {}) ⇒ Object

Return proxy object to enqueue jobs for object Options: pri (priority), delay (delay in secs), ttr (time to respond), queue (queue name)

Examples:

Model.async(:ttr => 300).do_something("foo")


27
28
29
 
# File 'lib/backburner/performable.rb', line 27

def async(opts={})
  Backburner::AsyncProxy.new(self, nil, opts)
end

#handle_asynchronously(method, opts = {}) ⇒ Object

Always handle an instance method asynchronously

Examples:

User.handle_asynchronously :send_welcome_email, queue: 'send-mail', delay: 10


45
46
47
 
# File 'lib/backburner/performable.rb', line 45

def handle_asynchronously(method, opts={})
  Backburner::Performable.handle_asynchronously(self, method, opts)
end

#handle_static_asynchronously(method, opts = {}) ⇒ Object

Always handle a class method asynchronously

Examples:

User.handle_static_asynchronously :update_recent_visitors, ttr: 300


52
53
54
 
# File 'lib/backburner/performable.rb', line 52

def handle_static_asynchronously(method, opts={})
  Backburner::Performable.handle_static_asynchronously(self, method, opts)
end

#perform(id, method, *args) ⇒ Object

Defines perform method for job processing

Examples:

perform(55, :do_something, "foo", "bar")


34
35
36
37
38
39
40
 
# File 'lib/backburner/performable.rb', line 34

def perform(id, method, *args)
  if id # instance
    find(id).send(method, *args)
  else # class method
    send(method, *args)
  end
end