lib/proletariat/subscriber.rb in proletariat-0.1.0 vs lib/proletariat/subscriber.rb in proletariat-0.1.1

@@ -13,9 +13,10 @@
       @queue_config            = queue_config
       @exception_handler_class = exception_handler_class
 
       bind_queue
       start_consumer
+      exception_handler
 
       @ticker = Concurrent::TimerTask.execute(execution: 5, timeout: 2) do
         acknowledge_messages
       end
     end