From 7de331fc41f9dc804c2cc4c79799944d93df8cf2 Mon Sep 17 00:00:00 2001
From: Andre Hahn <andre.hahn@tfgco.com>
Date: Fri, 18 May 2018 14:03:30 -0300
Subject: [PATCH] Fix nats rpc server shutdown

---
 cluster/nats_rpc_server.go | 1 +
 1 file changed, 1 insertion(+)

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)