class Emque::Consuming::CommandReceivers::HttpServer
Attributes
puma[RW]
Public Class Methods
new()
click to toggle source
# File lib/emque/consuming/command_receivers/http_server.rb, line 10 def initialize ENV["RACK_ENV"] = Emque::Consuming.application.emque_env initialize_puma end
Public Instance Methods
start()
click to toggle source
# File lib/emque/consuming/command_receivers/http_server.rb, line 15 def start @thread = Thread.new { puma.run } status end
Private Instance Methods
initialize_puma()
click to toggle source
# File lib/emque/consuming/command_receivers/http_server.rb, line 22 def initialize_puma conf = Puma::Configuration.new do |user_config| user_config.bind "tcp://#{config.status_host}:#{config.status_port}" user_config.app Handler.new end self.puma = Puma::Launcher.new(conf, :events => Puma::Events.null) puma.define_singleton_method :set_process_title do # we don't want puma to take over the process name end puma.define_singleton_method :setup_signals do # we don't want puma to handle signals end end