module Announcer::Publishers::ResquePublisher::SubscriptionJob
Public Class Methods
perform(serialized_sub, serialized_event)
click to toggle source
# File lib/announcer/publishers/resque_publisher.rb, line 71 def self.perform(serialized_sub, serialized_event) subscription = Subscription.deserialize(serialized_sub) event = Event.deserialize(serialized_event) subscription.handle(event) end
set_queue(queue)
click to toggle source
# File lib/announcer/publishers/resque_publisher.rb, line 67 def self.set_queue(queue) @queue = queue end