Skip to content

Instantly share code, notes, and snippets.

@dasch
Last active Sep 7, 2020
Embed
What would you like to do?
# app/consumers/hello_consumer.rb
class HelloConsumer < Racecar::Consumer
subscribes_to "some-topic"
def process(message)
puts "Received message: #{message.value}"
end
end
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment