Class: QueueBus::Rider

Inherits:
Object
  • Object
show all
Defined in:
lib/queue_bus/rider.rb

Overview

The Rider is meant to execute subscriptions.

When your application has subscriptions to an event we still need to enqueue some executor that will execute the block that was registered. The Rider will effectively ride the bus for your subscribed event. One Rider is launched for each subscription on an event.

Class Method Summary collapse

Class Method Details

.perform(attributes = {}) ⇒ Object 



10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
 
# File 'lib/queue_bus/rider.rb', line 10

def self.perform(attributes = {})
  sub_key = attributes['bus_rider_sub_key']
  app_key = attributes['bus_rider_app_key']
  raise 'No application key passed' if app_key.to_s == ''
  raise 'No subcription key passed' if sub_key.to_s == ''

  attributes ||= {}

  ::QueueBus.log_worker("Rider received: #{app_key} #{sub_key} #{attributes.inspect}")

  # attributes that should be available
  # attributes["bus_event_type"]
  # attributes["bus_app_key"]
  # attributes["bus_published_at"]
  # attributes["bus_driven_at"]

  # (now running with the real app that subscribed)
  ::QueueBus.dispatcher_execute(app_key, sub_key,
                                attributes.merge('bus_executed_at' => Time.now.to_i))
end