A consumer subscribing to more than one topics. Can it have separate process methods?

[rohitkumarrana67]

class TestConsumer< Racecar::Consumer
subscribes_to "comments", start_from_beginning: false
subscribes_to "events", start_from_beginning: false

def process(message)
p "Received message: #{message.value}"
end
end

[dasch]

You can easily set that up yourself:

def process(message)
  send("process_#{message.topic}", message)
end

private

def process_comments(message)
  # ...
end

def process_events(message)
  # ...
end
``