Sha256: c5f586bbbd0c077203307e8b7f2ac24b0a538c4cda6c08aa6be6f745646d6ed3

Contents?: true

Size: 245 Bytes

Versions: 27

Compression:

Stored size: 245 Bytes

Contents

# frozen_string_literal: true

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

27 entries across 27 versions & 1 rubygems

Version Path
racecar-2.11.0 examples/producing_consumer.rb
racecar-2.11.0.beta4 examples/producing_consumer.rb
racecar-2.11.0.beta3 examples/producing_consumer.rb
racecar-2.11.0.beta2 examples/producing_consumer.rb
racecar-2.11.0.beta1 examples/producing_consumer.rb
racecar-2.10.0 examples/producing_consumer.rb
racecar-2.10.0.beta2 examples/producing_consumer.rb
racecar-2.10.0.beta1 examples/producing_consumer.rb
racecar-2.9.0 examples/producing_consumer.rb
racecar-2.9.0.beta1 examples/producing_consumer.rb
racecar-2.8.2 examples/producing_consumer.rb
racecar-2.8.2.beta examples/producing_consumer.rb
racecar-2.8.1 examples/producing_consumer.rb
racecar-2.8.0.rc.1 examples/producing_consumer.rb
racecar-2.8.0.beta.2 examples/producing_consumer.rb
racecar-2.8.0.beta.1 examples/producing_consumer.rb
racecar-2.7.0 examples/producing_consumer.rb
racecar-2.7.0.beta1 examples/producing_consumer.rb
racecar-2.6.0 examples/producing_consumer.rb
racecar-2.5.0 examples/producing_consumer.rb