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