Class: WisperKafka::Consumer

Inherits:
Racecar::Consumer
  • Object
show all
Defined in:
lib/wisper_kafka/consumer.rb

Instance Method Summary collapse

Instance Method Details

#process(message) ⇒ Object

:reek:UtilityFunction



11
12
13
14
15
16
17
18
19
 
# 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