Make nats reusable after disconnection

2018-09-03 09:15:45 +10:00 · 2018-09-03 09:15:45 +10:00 · a3fcb74f93
commit a3fcb74f93
parent 109f13d3f2
1 changed files with 1 additions and 1 deletions
--- a/nats.go
+++ b/nats.go
@ -85,7 +85,7 @@ func setAddrs(addrs []string) []string {
 }

 func (n *nbroker) Connect() error {
-	if n.conn != nil {
+	if n.conn != nil && n.conn.IsConnected() {
 		return nil
 	}