Sha256: 0caa232df6b5079b4070a53d1ed8a1345c033c240ae019f8220b011d6fc0eceb
Contents?: true
Size: 1.47 KB
Versions: 41
Compression:
Stored size: 1.47 KB
Contents
# frozen_string_literal: true module Karafka # Messages namespace encapsulating all the logic that is directly related to messages handling module Messages # It provides lazy loading not only until the first usage, but also allows us to skip # using deserializer until we execute our logic. That way we can operate with # heavy-deserialization data without slowing down the whole application. class Message extend Forwardable attr_reader :raw_payload, :metadata def_delegators :metadata, *Metadata.members # @param raw_payload [Object] incoming payload before deserialization # @param metadata [Karafka::Messages::Metadata] message metadata object def initialize(raw_payload, metadata) @raw_payload = raw_payload @metadata = metadata @deserialized = false @payload = nil end # @return [Object] lazy-deserialized data (deserialized upon first request) def payload return @payload if deserialized? @payload = deserialize # We mark deserialization as successful after deserialization, as in case of an error # this won't be falsely set to true @deserialized = true @payload end # @return [Boolean] did we deserialize payload already def deserialized? @deserialized end private # @return [Object] deserialized data def deserialize metadata.deserializer.call(self) end end end end
Version data entries
41 entries across 41 versions & 1 rubygems