Method: Combi::Http::Server#on_message

Defined in:
lib/combi/buses/http.rb

#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" => path[1],
    "kind" => path[2],
    "payload" => JSON.parse(request.body)
  }
  @bus.on_message(message)
end