lib/fluffle/server.rb in fluffle-0.8.0 vs lib/fluffle/server.rb in fluffle-0.8.1
- old
+ new
@@ -109,10 +109,10 @@
readables = io.first
signal = readables.first.gets.strip
Fluffle.logger.info "Received #{signal}; shutting down..."
- @channel.work_pool.shutdown
+ @channel.close
@handler_pool.shutdown
unless @handler_pool.wait_for_termination(@shutdown_timeout)
# `wait_for_termination` returns false if it didn't shut down in time,
# so we need to kill it