lib/mimi/messaging/adapters/memory.rb in mimi-messaging-1.2.6 vs lib/mimi/messaging/adapters/memory.rb in mimi-messaging-1.2.7

@@ -115,10 +115,10 @@
           processor = request_processors[queue_name].sample
           response = processor.call_query(method_name, transmitted_message(message), {})
           serialize(response)
         end
 
-        def dispatch_event(target, message_serialized, _opts = {})
+        def dispatch_event(target, message, _opts = {})
           topic_name, event_type = target.split("#")
           processors = event_processors[topic_name] || []
           processor_queues = event_processors_with_queue[topic_name] || {}
           processor_queues.values.each do |same_queue_processors|
             processors << same_queue_processors.sample