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

Version Path
karafka-2.0.23 lib/karafka/messages/message.rb
karafka-2.0.22 lib/karafka/messages/message.rb
karafka-2.0.21 lib/karafka/messages/message.rb
karafka-2.0.20 lib/karafka/messages/message.rb
karafka-2.0.19 lib/karafka/messages/message.rb
karafka-2.0.18 lib/karafka/messages/message.rb
karafka-2.0.17 lib/karafka/messages/message.rb
karafka-2.0.16 lib/karafka/messages/message.rb
karafka-2.0.15 lib/karafka/messages/message.rb
karafka-2.0.14 lib/karafka/messages/message.rb
karafka-2.0.13 lib/karafka/messages/message.rb
karafka-2.0.12 lib/karafka/messages/message.rb
karafka-2.0.11 lib/karafka/messages/message.rb
karafka-2.0.10 lib/karafka/messages/message.rb
karafka-2.0.9 lib/karafka/messages/message.rb
karafka-2.0.8 lib/karafka/messages/message.rb
karafka-2.0.7 lib/karafka/messages/message.rb
karafka-2.0.6 lib/karafka/messages/message.rb
karafka-2.0.5 lib/karafka/messages/message.rb
karafka-2.0.4 lib/karafka/messages/message.rb