lib/phobos/actions/process_batch.rb in phobos-1.8.0 vs lib/phobos/actions/process_batch.rb in phobos-1.8.1

- old
+ new

@@ -1,5 +1,7 @@ +# frozen_string_literal: true + module Phobos module Actions class ProcessBatch include Phobos::Instrumentation @@ -15,10 +17,10 @@ offset_lag: batch.offset_lag ) end def execute - instrument('listener.process_batch', @metadata) do |metadata| + instrument('listener.process_batch', @metadata) do |_metadata| @batch.messages.each do |message| Phobos::Actions::ProcessMessage.new( listener: @listener, message: message, listener_metadata: @listener_metadata