Contents

# frozen_string_literal: true

module QueueBus
  # 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 Rider
    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
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
queue-bus-0.13.3	lib/queue_bus/rider.rb
queue-bus-0.13.2	lib/queue_bus/rider.rb
queue-bus-0.13.1	lib/queue_bus/rider.rb
queue-bus-0.13.0	lib/queue_bus/rider.rb
queue-bus-0.12.0	lib/queue_bus/rider.rb
queue-bus-0.11.0	lib/queue_bus/rider.rb
queue-bus-0.10.0	lib/queue_bus/rider.rb
queue-bus-0.9.1	lib/queue_bus/rider.rb