1 2 3 4 5 6 7
class DistributionWorker include Sidekiq::Worker def perform(status_id) FanOutOnWriteService.new.call(Status.find(status_id)) end end