diff --git a/nats.go b/nats.go index 70d8891..49c07ec 100644 --- 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 }