lib/dispatch-rider/demultiplexer.rb in dispatch-rider-0.2.3 vs lib/dispatch-rider/demultiplexer.rb in dispatch-rider-0.2.4
- old
+ new
@@ -34,9 +34,10 @@
def dispatch_message(message)
dispatcher.dispatch(message)
rescue => exception
error_handler.call(message, exception)
+ false
end
def do_loop
catch(:done) do
loop do