lib/larva/processor.rb in larva-1.0.0 vs lib/larva/processor.rb in larva-1.0.1

@@ -3,11 +3,11 @@
     def self.process(message)
       new(message).process_with_logging
     end
 
     attr_accessor :message, :action, :entity, :id
-    def initialize(message)
-      @message = message
+    def initialize(raw_message)
+      @message = HashWithIndifferentAccess.new(raw_message)
       @action = message[:action]
       @entity = message[:entity]
       @id = message[:id]
     end