Contents

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

  def process(message)
    value = message.value.reverse

    produce value, topic: "reverse-messages"
  end
end

Version data entries

26 entries across 26 versions & 1 rubygems

Version	Path
racecar-1.3.0	examples/producing_consumer.rb
racecar-1.2.1	examples/producing_consumer.rb
racecar-2.0.0	examples/producing_consumer.rb
racecar-2.0.0.beta6	examples/producing_consumer.rb
racecar-1.2.0	examples/producing_consumer.rb
racecar-1.1.0	examples/producing_consumer.rb
racecar-2.0.0.beta5	examples/producing_consumer.rb
racecar-2.0.0.beta4	examples/producing_consumer.rb
racecar-2.0.0.beta3	examples/producing_consumer.rb
racecar-2.0.0.beta2	examples/producing_consumer.rb
racecar-2.0.0.beta1	examples/producing_consumer.rb
racecar-1.0.1	examples/producing_consumer.rb
racecar-2.0.0.alpha3	examples/producing_consumer.rb
racecar-2.0.0.alpha2	examples/producing_consumer.rb
racecar-2.0.0.alpha1	examples/producing_consumer.rb
racecar-1.0.0	examples/producing_consumer.rb
racecar-0.5.0	examples/producing_consumer.rb
racecar-0.5.0.beta2	examples/producing_consumer.rb
racecar-0.5.0.beta1	examples/producing_consumer.rb
racecar-0.4.2	examples/producing_consumer.rb