lib/dispatch-rider/demultiplexer.rb in dispatch-rider-1.3.2 vs lib/dispatch-rider/demultiplexer.rb in dispatch-rider-1.3.3

@@ -70,10 +70,12 @@
 
     def handle_next_queue_item
       queue.pop do |message|
         begin
           logger.info "Starting execution of: #{message_info_fragment(message)}"
-          dispatch_message(message)
+          dispatch_message(message).tap {
+            logger.info "Succeded execution of: #{message_info_fragment(message)}"
+          }
         ensure
           logger.info "Completed execution of: #{message_info_fragment(message)}"
         end
       end
     end