class Application
Public Class Methods
avro_registry()
click to toggle source
# File lib/rks/application.rb, line 13 def avro_registry @avro ||= AvroTurf::Messaging.new( schemas_path: "./app/schemas", registry_url: Application.config.avro_registry_url ) end
logger()
click to toggle source
# File lib/rks/application.rb, line 9 def logger @logger ||= RKS::Logger.init end
run()
click to toggle source
# File lib/rks/application.rb, line 20 def run Application.logger.info message: "Application started" RKS::Event::Handler.router.routes.keys.each do |event_name| topic = [config.env,event_name].join("-") Kafka.consumer.subscribe(topic) end # This will loop indefinitely, yielding each message in turn. Kafka.consumer.each_message do |message| RKS::Event::Processor.process(correlation_id: message.key, event: sanitized_event_name(message.topic), payload: message.value) end end
sanitized_event_name(topic)
click to toggle source
# File lib/rks/application.rb, line 33 def sanitized_event_name(topic) topic.gsub("#{config.env}-", "") end