f

Author: JustSnow

lib/table_sync/publishing/raw.rb

@@ -22,7 +22,7 @@ def initialize(attributes = {})
     self.original_attributes  = attributes[:original_attributes]
     self.custom_version       = attributes[:custom_version]
     self.routing_key          = attributes[:routing_key]
-    self.headers              = attributes[:headers]
+    self.headers              = attributes[:headers] || {}
     self.event                = attributes.fetch(:event, :update).to_sym
     self.compress             = attributes.fetch(:compress, false)
   end