class Radar::App::Server
Public Instance Methods
start()
click to toggle source
# File lib/radar/app/server.rb, line 9 def start multiplexer = MultiplexedProcessor.new analyzer_controller = Radar::App::AnalyzerController.new multiplexer.register_processor( 'PortfolioAnalyzer', ProcessorFactory.create_processor(Radar::API::AnalyzerController::Processor). new(analyzer_controller) ) unless Radar::App.transaction_importer.nil? multiplexer.register_processor( 'TransactionImporter', ProcessorFactory.create_processor(Radar::API::TransactionImporter::Processor). new(Radar::App.transaction_importer) ) end unless Radar::App.transaction_file_importer.nil? multiplexer.register_processor( 'TransactionFileImporter', ProcessorFactory.create_processor(Radar::API::TransactionFileImporter::Processor). new(Radar::App.transaction_file_importer) ) end multiplexer.register_processor( 'Healthz', ProcessorFactory.create_processor(Radar::API::Healthz::Processor). new(Radar::App::Healthz.new) ) transport = Thrift::ServerSocket.new(port) server = Thrift::NonblockingServer.new(multiplexer, transport, Thrift::FramedTransportFactory.new) logger.info { "Starting app on port #{port}..." } server.serve end