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 



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

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,
    subject: key_avro_schema_subject
  )
end

#avro_message_value ⇒ Object 



16
17
18
19
20
21
22
 
# 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,
    subject: value_avro_schema_subject
  )
end