class EventRouter::DeliveryAdapters::Workers::SidekiqDestinationDeliveryWorker
Public Instance Methods
perform(destination_name, serialized_event, serialized_payload)
click to toggle source
# File lib/event_router/delivery_adapters/workers/sidekiq_destination_delivery_worker.rb, line 9 def perform(destination_name, serialized_event, serialized_payload) event = EventRouter.deserialize(serialized_event) destination = event.destinations[destination_name.to_sym] return unless destination payload = if destination.prefetch_payload? EventRouter.deserialize(serialized_payload) else destination.extra_payload(event) end destination.process(event, payload) end