fixed missing else statement when creating nats connection

This commit is contained in:
Lenny-Campino Hartmann 2018-08-09 08:22:18 +02:00
parent 2f076524d4
commit c0063a859c
1 changed files with 2 additions and 1 deletions

View File

@ -63,8 +63,9 @@ func (conn *NATSConn) Send(msg string) error {
var err error var err error
if conn.ep.NATS.User != "" && conn.ep.NATS.Pass != "" { if conn.ep.NATS.User != "" && conn.ep.NATS.Pass != "" {
conn.conn, err = nats.Connect(addr, nats.UserInfo(conn.ep.NATS.User, conn.ep.NATS.Pass)) conn.conn, err = nats.Connect(addr, nats.UserInfo(conn.ep.NATS.User, conn.ep.NATS.Pass))
} else {
conn.conn, err = nats.Connect(addr)
} }
conn.conn, err = nats.Connect(addr)
if err != nil { if err != nil {
conn.close() conn.close()
return err return err