Method: DigitalFabric::AgentProxy#run

Defined in:
lib/tipi/digital_fabric/agent_proxy.rb

#run ⇒ Object 



31
32
33
34
35
36
37
38
39
40
41
42
43
 
# File 'lib/tipi/digital_fabric/agent_proxy.rb', line 31

def run
  @fiber = Fiber.current
  @service.mount(route, self)
  @mounted = true
  # keep_alive_timer = spin_loop("#{@fiber.tag}-keep_alive", interval: 5) { keep_alive }
  process_incoming_messages(false)
rescue GracefulShutdown
  puts "Proxy got graceful shutdown, left: #{@requests.size} requests" if @requests.size > 0
  move_on_after(15) { process_incoming_messages(true) }
ensure
  # keep_alive_timer&.stop
  unmount
end