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

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

Class Method Summary collapse

Class Method Details

.perform(serialized_sub, serialized_event) ⇒ Object 



44
45
46
47
48
 
# File 'lib/ribbon/event_bus/publishers/resque_publisher.rb', line 44

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 



40
41
42
 
# File 'lib/ribbon/event_bus/publishers/resque_publisher.rb', line 40

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