module Messaging
  class SidekiqWorker
    include Sidekiq::Worker
    sidekiq_options queue: 'messaging'

    def perform(raw_message, handler_name)
      message = Messaging::Message::FromJson.(raw_message)
      handler = handler_name.constantize
      handler.call message
    end
  end
end