lib/dispatch-rider/dispatcher.rb in dispatch-rider-1.0.3 vs lib/dispatch-rider/dispatcher.rb in dispatch-rider-1.1.4
- old
+ new
@@ -17,10 +17,10 @@
@handler_registrar = Registrars::Handler.new
end
def dispatch(message)
callbacks.invoke(:dispatch_message, message) do
- handler_registrar.fetch(message.subject).new.do_process(message.body)
+ handler_registrar.fetch(message.subject).new.do_process(message)
end
true # success => true (delete message)
end
private