Sha256: df5242482ad1d31a786e3d65b09484eb022b33fc64e12cf27370ecbcc7a78616
Contents?: true
Size: 385 Bytes
Versions: 19
Compression:
Stored size: 385 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Deserializers
# Default message headers deserializer
class Headers
# @param metadata [Karafka::Messages::Metadata] metadata object from which we obtain the
# `#raw_headers`
# @return [Hash] expected message headers hash
def call(metadata)
metadata.raw_headers
end
end
end
end
Version data entries
19 entries across 19 versions & 1 rubygems