module Avromatic::Model::MessagingSerialization::Registration

Public Instance Methods

register_schemas!() click to toggle source
# File lib/avromatic/model/messaging_serialization.rb, line 60
def register_schemas!
  register_schema(key_avro_schema, subject: key_avro_schema_subject) if key_avro_schema
  register_schema(value_avro_schema, subject: value_avro_schema_subject)
  nil
end

Private Instance Methods

register_schema(schema, subject: nil) click to toggle source
# File lib/avromatic/model/messaging_serialization.rb, line 68
def register_schema(schema, subject: nil)
  avro_messaging.registry.register(subject || schema.fullname, schema)
end