class EventRouter::DeliveryAdapters::Sidekiq

Constants

REQUIRED_OPTIONS

Public Class Methods

deliver(event) click to toggle source
# File lib/event_router/delivery_adapters/sidekiq.rb, line 26
def deliver(event)
  Helpers::Sidekiq.process_event(event)
end
deliver_async(event) click to toggle source
# File lib/event_router/delivery_adapters/sidekiq.rb, line 30
def deliver_async(event)
  serialized_event  = EventRouter.serialize(event)
  options           = EventRouter::Helpers::Event.event_options(event, self)

  Workers::SidekiqEventDeliveryWorker
    .set(queue: options[:queue], retry: options[:retry])
    .perform_async(serialized_event)
end
validate_options!(options) click to toggle source
# File lib/event_router/delivery_adapters/sidekiq.rb, line 18
def validate_options!(options)
  missing_options = REQUIRED_OPTIONS - options.compact.keys

  return true if missing_options.empty?

  raise Errors::RequiredOptionError.new(options: missing_options, adapter: self)
end