Module: Ribbon::EventBus::Publishers::ResquePublisher::SubscriptionJob

Defined in:
lib/ribbon/event_bus/publishers/resque_publisher.rb

Overview

PublisherJob

Class Method Summary collapse

Class Method Details

.perform(serialized_sub, serialized_event) ⇒ Object 



65
66
67
68
69
 
# File 'lib/ribbon/event_bus/publishers/resque_publisher.rb', line 65

def self.perform(serialized_sub, serialized_event)
  subscription = Subscription.deserialize(serialized_sub)
  event = Event.deserialize(serialized_event)
  subscription.handle(event)
end

.set_queue(queue) ⇒ Object 



61
62
63
 
# File 'lib/ribbon/event_bus/publishers/resque_publisher.rb', line 61

def self.set_queue(queue)
  @queue = queue
end