Module: Riffer::Messages::Converter

Included in:
Agent, Providers::Base
Defined in:
lib/riffer/messages/converter.rb

Overview

Module for converting hashes to message objects.

Included in Agent and Provider classes to handle message normalization.

Instance Method Summary collapse

Instance Method Details

#convert_to_message_object(msg) ⇒ Object

Converts a hash or message object to a Riffer::Messages::Base subclass.

msg

Hash or Riffer::Messages::Base - the message to convert

Returns Riffer::Messages::Base subclass.

Raises Riffer::ArgumentError if the message format is invalid.



14
15
16
17
18
19
20
21
22
 
# File 'lib/riffer/messages/converter.rb', line 14

def convert_to_message_object(msg)
  return msg if msg.is_a?(Riffer::Messages::Base)

  unless msg.is_a?(Hash)
    raise Riffer::ArgumentError, "Message must be a Hash or Message object, got #{msg.class}"
  end

  convert_hash_to_message(msg)
end