Fix nats rpc server shutdown

topfreegames · May 18, 2018 · 7de331f · 7de331f
1 parent 507c0c7
commit 7de331f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/cluster/nats_rpc_server.go b/cluster/nats_rpc_server.go
@@ -128,6 +128,7 @@ func (ns *NatsRPCServer) SubscribeToUserMessages(uid string, svType string) (*na
 
 func (ns *NatsRPCServer) handleMessages() {
 	defer (func() {
+		ns.conn.Close()
 		close(ns.unhandledReqCh)
 		close(ns.subChan)
 		close(ns.bindingsChan)