lib/ruby_skynet/connection.rb in ruby_skynet-0.8.1 vs lib/ruby_skynet/connection.rb in ruby_skynet-1.0.0
- old
+ new
@@ -233,10 +233,10 @@
pool = GenePool.new(pool_config) do
new(server, params)
end
# Cleanup corresponding connection pool when a server terminates
- RubySkynet.services.on_server_removed(server) do
+ RubySkynet.service_registry.on_server_removed(server) do
pool = @@connection_pools.delete(server)
# Cannot close all the connections since they could still be in use
pool.remove_idle(0) if pool
#pool.close if pool
logger.debug "Connection pool released"