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