Contents

# frozen_string_literal: true

class BatchConsumer < Racecar::Consumer
  subscribes_to "messages", start_from_beginning: false

  def process_batch(messages)
    messages.each do |message|
      puts message.value
    end
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version	Path
racecar-2.11.0	examples/batch_consumer.rb
racecar-2.11.0.beta4	examples/batch_consumer.rb
racecar-2.11.0.beta3	examples/batch_consumer.rb
racecar-2.11.0.beta2	examples/batch_consumer.rb
racecar-2.11.0.beta1	examples/batch_consumer.rb
racecar-2.10.0	examples/batch_consumer.rb
racecar-2.10.0.beta2	examples/batch_consumer.rb
racecar-2.10.0.beta1	examples/batch_consumer.rb
racecar-2.9.0	examples/batch_consumer.rb
racecar-2.9.0.beta1	examples/batch_consumer.rb