Class: Activr::Async::Resque::RouteActivity

Inherits:
Object
  • Object
show all
Defined in:
lib/activr/async/resque.rb

Overview

Class to handle :route_activity hook thanks to a Resque job

Class Method Summary collapse

Class Method Details

.enqueue(activity) ⇒ Object

Enqueue job



14
15
16
 
# File 'lib/activr/async/resque.rb', line 14

def enqueue(activity)
  ::Resque.enqueue(self, activity.to_hash)
end

.perform(activity_hash) ⇒ Object

Perform job



19
20
21
22
23
24
25
26
 
# File 'lib/activr/async/resque.rb', line 19

def perform(activity_hash)
  # unserialize argument
  activity_hash = Activr::Activity.unserialize_hash(activity_hash)
  activity = Activr::Activity.from_hash(activity_hash)

  # call hook
  Activr::Async.route_activity(activity)
end