Sha256: b70bde3aca8a988b35fa76bfa1279f0ded5bd85cf9b504442d75ad39cb6ed1cb
Contents?: true
Size: 683 Bytes
Versions: 69
Compression:
Stored size: 683 Bytes
Contents
# frozen_string_literal: true
module Karafka
# Module for all supported by default serialization and deserialization ways.
module Serialization
# Namespace for json serializers and deserializers.
module Json
# Default Karafka Json deserializer for loading JSON data.
class Deserializer
# @param message [Karafka::Messages::Message] Message object that we want to deserialize
# @return [Hash] hash with deserialized JSON data
def call(message)
# nil payload can be present for example for tombstone messages
message.raw_payload.nil? ? nil : ::JSON.parse(message.raw_payload)
end
end
end
end
end
Version data entries
69 entries across 69 versions & 1 rubygems