lib/cyclone_lariat/middleware.rb in cyclone_lariat-1.0.0.rc2 vs lib/cyclone_lariat/middleware.rb in cyclone_lariat-1.0.0.rc3

@@ -1,10 +1,11 @@
 # frozen_string_literal: true
 
 require 'cyclone_lariat/repo/messages'
 require 'cyclone_lariat/core'
 require 'luna_park/errors'
+require 'cyclone_lariat/messages/builder'
 require 'json'
 
 module CycloneLariat
   class Middleware
     attr_reader :config
@@ -21,10 +22,10 @@
 
       message_notifier&.info 'Receive message', message: msg, queue: queue
       return if msg.is_a? String
 
       catch_standard_error(queue, msg) do
-        event = Messages::V1::Event.wrap(msg)
+        event = Messages::Builder.new(raw_message: msg).call
 
         store_in_dataset(event) do
           catch_business_error(event, &block)
         end
       end