Method: Messaging::Adapters::Postgres::SerializedMessage#to_message

Defined in:: lib/messaging/adapters/postgres/serialized_message.rb

#to_message ⇒ `Object`



31
32
33

# File 'lib/messaging/adapters/postgres/serialized_message.rb', line 31

def to_message
  message_type.constantize.new(data.merge(stream_position: stream_position))
end