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