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