lib/dispatch-rider/demultiplexer.rb in dispatch-rider-1.2.10 vs lib/dispatch-rider/demultiplexer.rb in dispatch-rider-1.2.11

@@ -40,13 +40,15 @@
       end
     end
 
     def with_current_message(message)
       @current_message = message
-      yield
+      result = yield
       @current_message = nil
+      result
     end
 
+    # This needs to return true/false based on the success of the jobs!
     def dispatch_message(message)
       with_current_message(message) do
         dispatcher.dispatch(message)
       end
     rescue => exception