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