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