Sha256: a130518e88548f9f99a75d040959f0ad6190898a02947d8e95c91590843b61ac
Contents?: true
Size: 1.91 KB
Versions: 56
Compression:
Stored size: 1.91 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
class << self
# @return [Object] general parser
# @note We cache it here for performance reasons. It is 2.5x times faster than getting it
# via the config chain.
def parser
@parser ||= App.config.internal.messages.parser
end
end
attr_reader :metadata
# raw payload needs to be mutable as we want to have option to change it in the parser
# prior to the final deserialization
attr_accessor :raw_payload
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
self.class.parser.call(self)
end
end
end
end
Version data entries
56 entries across 56 versions & 1 rubygems