Class: Emque::Consuming::CommandReceivers::HttpServer

Inherits:
Base
  • Object
show all
Defined in:
lib/emque/consuming/command_receivers/http_server.rb

Defined Under Namespace

Classes: Handler, Logger

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods inherited from Base

#restart, #status, #stop

Constructor Details

#initialize ⇒ HttpServer

Returns a new instance of HttpServer.



10
11
12
13
 
# File 'lib/emque/consuming/command_receivers/http_server.rb', line 10

def initialize
  ENV["RACK_ENV"] = Emque::Consuming.application.emque_env
  initialize_puma
end

Instance Attribute Details

#puma ⇒ Object

Returns the value of attribute puma.



8
9
10
 
# File 'lib/emque/consuming/command_receivers/http_server.rb', line 8

def puma
  @puma
end

Instance Method Details

#start ⇒ Object 



15
16
17
18
 
# File 'lib/emque/consuming/command_receivers/http_server.rb', line 15

def start
  @thread = Thread.new { puma.run }
  status
end