Sha256: 572cdadd2e7ea3cd038532c6d77ca2346b571ba5fc398a5fa26f4c8f09af57f0
Contents?: true
Size: 295 Bytes
Versions: 34
Compression:
Stored size: 295 Bytes
Contents
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
Version data entries
34 entries across 34 versions & 1 rubygems