Class: Karafka::Messages::Parser

Inherits:

Object

• Object
• Karafka::Messages::Parser

Defined in:

lib/karafka/messages/parser.rb

Overview

Default message parser. The only thing it does, is calling the deserializer

Direct Known Subclasses

Pro::Encryption::Messages::Parser

Instance Method Summary

• #call(message) ⇒ Object

  Deserialized payload.

Instance Method Details

#call(message) ⇒ Object

Returns deserialized payload.

Parameters:

• message (::Karafka::Messages::Message)

Returns:

• (Object) —

  deserialized payload

# File 'lib/karafka/messages/parser.rb', line 9

def call(message)
  message.metadata.deserializers.payload.call(message)
end