lib/dispatch-rider/subscriber.rb in dispatch-rider-0.0.3 vs lib/dispatch-rider/subscriber.rb in dispatch-rider-0.0.4

@@ -21,9 +21,13 @@
     def register_handlers(*names)
       names.each {|name| register_handler(name)}
       self
     end
 
+    def on_dispatch_error(&block)
+      dispatcher.on_error &block
+    end
+
     def setup_demultiplexer(queue_name)
       queue = queue_service_registrar.fetch(queue_name)
       @demultiplexer ||= DispatchRider::Demultiplexer.new(queue, dispatcher)
       self
     end