Class: Karafka::Messages::Parser

Inherits:
Object
  • Object
show all
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 collapse

Instance Method Details

#call(message) ⇒ Object

Returns deserialized payload.

Parameters:

Returns:

  • (Object)

    deserialized payload



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

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