lib/phobos/actions/process_batch.rb in phobos-1.6.1 vs lib/phobos/actions/process_batch.rb in phobos-1.7.0

@@ -16,20 +16,16 @@
         )
       end
 
       def execute
         instrument('listener.process_batch', @metadata) do |metadata|
-          time_elapsed = measure do
-            @batch.messages.each do |message|
-              Phobos::Actions::ProcessMessage.new(
-                listener: @listener,
-                message: message,
-                listener_metadata: @listener_metadata
-              ).execute
-            end
+          @batch.messages.each do |message|
+            Phobos::Actions::ProcessMessage.new(
+              listener: @listener,
+              message: message,
+              listener_metadata: @listener_metadata
+            ).execute
           end
-
-          metadata.merge!(time_elapsed: time_elapsed)
         end
       end
     end
   end
 end