queue-bus.rb in queue-bus-0.6.0

- old
+ new

@@ -9,10 +9,11 @@
   autoload :Dispatchers,      'queue_bus/dispatchers'
   autoload :Driver,           'queue_bus/driver'
   autoload :Heartbeat,        'queue_bus/heartbeat'
   autoload :Local,            'queue_bus/local'
   autoload :Matcher,          'queue_bus/matcher'
+  autoload :Middleware,       'queue_bus/middleware'
   autoload :Publishing,       'queue_bus/publishing'
   autoload :Publisher,        'queue_bus/publisher'
   autoload :Rider,            'queue_bus/rider'
   autoload :Subscriber,       'queue_bus/subscriber'
   autoload :Subscription,     'queue_bus/subscription'
@@ -37,10 +38,10 @@
                             :before_publish=, :before_publish_callback,
                             :logger=, :logger, :log_application, :log_worker,
                             :hostname=, :hostname,
                             :adapter=, :adapter,
                             :incoming_queue=, :incoming_queue,
-                            :redis
+                            :redis, :worker_middleware_stack
 
     def_delegators :_dispatchers, :dispatch, :dispatchers, :dispatcher_by_key, :dispatcher_execute
 
     protected
 