lib/dispatch-rider/demultiplexer.rb in dispatch-rider-0.2.0 vs lib/dispatch-rider/demultiplexer.rb in dispatch-rider-0.2.1

- old
+ new

@@ -16,11 +16,11 @@ def start do_loop do begin handle_next_queue_item - rescue Exception => exception + rescue => exception error_handler.call(Message.new(subject: "TopLevelError", body: {}), exception) throw :done end end self @@ -32,10 +32,10 @@ private def dispatch_message(message) dispatcher.dispatch(message) - rescue Exception => exception + rescue => exception error_handler.call(message, exception) end def do_loop catch(:done) do