class WisperKafka::Consumer

Public Instance Methods

process(message) click to toggle source

:reek: UtilityFunction

# File lib/wisper_kafka/consumer.rb, line 11
def process(message)
  parsed_message = JSON.parse(message.value, symbolize_names: true)

  subscriber = parsed_message.fetch(:subscriber)
  event = parsed_message.fetch(:event)
  args = parsed_message.fetch(:args)

  Object.const_get(subscriber).public_send(event, *args)
end