lib/dispatch-rider/subscriber.rb in dispatch-rider-0.0.7 vs lib/dispatch-rider/subscriber.rb in dispatch-rider-0.1.0

@@ -21,16 +21,12 @@
     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)
+    def setup_demultiplexer(queue_name, error_handler = DispatchRider::DefaultErrorHandler)
       queue = queue_service_registrar.fetch(queue_name)
-      @demultiplexer ||= DispatchRider::Demultiplexer.new(queue, dispatcher)
+      @demultiplexer ||= DispatchRider::Demultiplexer.new(queue, dispatcher, error_handler)
       self
     end
 
     def process
       interuption_count = 0