lib/dispatch-rider/dispatcher.rb in dispatch-rider-0.0.4 vs lib/dispatch-rider/dispatcher.rb in dispatch-rider-0.0.5

@@ -19,9 +19,10 @@
       @error_handler = block
     end
 
     def dispatch(message)
       handler_registrar.fetch(message.subject).process(message.body)
+      true # success => true (delete message)
     rescue Exception => exception
       @error_handler.call(message, exception)
     end
 
     private