Module: Ribbon::EventBus::Publishers::ResquePublisher::PublisherJob

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

Class Method Summary collapse

Class Method Details

.perform(sub_queue_format, serialized_event) ⇒ Object 



23
24
25
26
27
28
29
30
31
32
33
34
35
36
 
# File 'lib/ribbon/event_bus/publishers/resque_publisher.rb', line 23

def self.perform(sub_queue_format, serialized_event)
  event = Event.deserialize(serialized_event)

  event.subscriptions.each { |s|
    SubscriptionJob.set_queue(
      (sub_queue_format % {
        event: event.name,
        priority: s.priority
      }).to_sym
    )

    Resque.enqueue(SubscriptionJob, s.serialize, event.serialize)
  }
end

.set_queue(queue) ⇒ Object 



19
20
21
 
# File 'lib/ribbon/event_bus/publishers/resque_publisher.rb', line 19

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