Class: Karafka::Pro::ScheduledMessages::Deserializers::Payload

Inherits:

Object

• Object
• Karafka::Pro::ScheduledMessages::Deserializers::Payload

Defined in:

lib/karafka/pro/scheduled_messages/deserializers/payload.rb

Overview

States payload deserializer We only deserialize states data and never anything else. Other payloads are the payloads we are expected to proxy, thus there is no need to deserialize them in any context. Their appropriate target topics should have expected deserializers

Instance Method Summary

• #call(message) ⇒ Hash

  Deserialized data.

Instance Method Details

#call(message) ⇒ Hash

Returns deserialized data.

Parameters:

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

Returns:

• (Hash) —

  deserialized data

# File 'lib/karafka/pro/scheduled_messages/deserializers/payload.rb', line 42

def call(message)
  JSON.parse(
    Zlib::Inflate.inflate(message.raw_payload),
    symbolize_names: true
  )
end