Module: Avromatic::Model::MessagingSerialization::Encode

Included in:
Avromatic::Model::MessagingSerialization
Defined in:
lib/avromatic/model/messaging_serialization.rb

Instance Method Summary collapse

Instance Method Details

#avro_message_key ⇒ Object 



23
24
25
26
27
28
29
 
# File 'lib/avromatic/model/messaging_serialization.rb', line 23

def avro_message_key
  raise 'Model has no key schema' unless key_avro_schema
  avro_messaging.encode(
    key_attributes_for_avro,
    schema_name: key_avro_schema.fullname
  )
end

#avro_message_value ⇒ Object 



16
17
18
19
20
21
 
# File 'lib/avromatic/model/messaging_serialization.rb', line 16

def avro_message_value
  avro_messaging.encode(
    value_attributes_for_avro,
    schema_name: value_avro_schema.fullname
  )
end