Sha256: 2483a104de438f6ee7c2a6573b099ff1fddcf06639dbbc17d91356a05795b8e6
Contents?: true
Size: 531 Bytes
Versions: 21
Compression:
Stored size: 531 Bytes
Contents
# frozen_string_literal: true module Karafka module Web # Web reporting deserializer # # @note We use `symbolize_names` because we want to use the same convention of hash building # for producing, consuming and displaying metrics related data class Deserializer # @param message [::Karafka::Messages::Message] # @return [Object] deserialized data def call(message) ::JSON.parse( message.raw_payload, symbolize_names: true ) end end end end
Version data entries
21 entries across 21 versions & 1 rubygems