Class: Combi::Http::Server

Inherits:
Object
  • Object
show all
Defined in:
lib/combi/buses/http.rb

Instance Method Summary collapse

Constructor Details

#initialize(bus) ⇒ Server

Returns a new instance of Server.



10
11
12
 
# File 'lib/combi/buses/http.rb', line 10

def initialize(bus)
  @bus = bus
end

Instance Method Details

#on_message(request) ⇒ Object 



14
15
16
17
18
19
20
21
22
 
# File 'lib/combi/buses/http.rb', line 14

def on_message(request)
  path = request.path.split('/')
  message = {
    service_name: path[1],
    kind: path[2],
    payload: Yajl::Parser.parse(request.body, symbolize_keys: true)
  }
  @bus.on_message(message)
end