lib/phobos.rb in phobos-1.8.1 vs lib/phobos.rb in phobos-1.8.2.pre.beta1

- old
+ new

@@ -20,11 +20,13 @@ require 'phobos/instrumentation' require 'phobos/errors' require 'phobos/listener' require 'phobos/actions/process_batch' require 'phobos/actions/process_message' +require 'phobos/actions/process_batch_inline' require 'phobos/producer' require 'phobos/handler' +require 'phobos/batch_handler' require 'phobos/echo_handler' require 'phobos/executor' Thread.abort_on_exception = true