diff --git a/cluster/nats_rpc_server.go b/cluster/nats_rpc_server.go
index 6919cd3e..91f4dc61 100644
--- 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)