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