Contents

# frozen_string_literal: true

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

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

Version data entries

17 entries across 17 versions & 1 rubygems

Version	Path
racecar-2.8.2	examples/batch_consumer.rb
racecar-2.8.2.beta	examples/batch_consumer.rb
racecar-2.8.1	examples/batch_consumer.rb
racecar-2.8.0.rc.1	examples/batch_consumer.rb
racecar-2.8.0.beta.2	examples/batch_consumer.rb
racecar-2.8.0.beta.1	examples/batch_consumer.rb
racecar-2.7.0	examples/batch_consumer.rb
racecar-2.7.0.beta1	examples/batch_consumer.rb
racecar-2.6.0	examples/batch_consumer.rb
racecar-2.5.0	examples/batch_consumer.rb
racecar-2.4.0	examples/batch_consumer.rb
racecar-2.3.1	examples/batch_consumer.rb
racecar-2.3.0	examples/batch_consumer.rb
racecar-2.3.0.alpha1	examples/batch_consumer.rb
racecar-2.2.0	examples/batch_consumer.rb
racecar-2.1.1	examples/batch_consumer.rb
racecar-2.1.0	examples/batch_consumer.rb