lib/cyclone_lariat/middleware.rb in cyclone_lariat-0.2.2 vs lib/cyclone_lariat/middleware.rb in cyclone_lariat-0.2.3

@@ -14,10 +14,12 @@
 
     def call(_worker_instance, queue, _sqs_msg, body, &block)
       log_received_message queue, body
 
       catch_standard_error(queue, body) do
+        return true unless check(body[:Message])
+        
         event = Event.wrap(JSON.parse(body[:Message]))
 
         catch_business_error(event) do
           store_in_dataset(event, &block)
         end
@@ -51,8 +53,17 @@
     def catch_standard_error(queue, body)
       yield
     rescue StandardError => e
       errors_notifier&.error(e, queue: queue, aws_message_id: body[:MessageId], message: body[:Message])
       raise e
+    end
+
+    def check(msg)
+      if msg.nil? || msg.empty?
+        errors_notifier&.error(Errors::EmptyMessage.new)
+        false
+      else
+        true
+      end
     end
   end
 end