Skip to content

Commit

Permalink
Merge pull request #20 from kumparan/hotfix/update-log-reconnect
Browse files Browse the repository at this point in the history
update reconnected log
  • Loading branch information
atjhoendz authored Nov 17, 2022
2 parents 4a75b64 + b993ff2 commit b54d146
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion jetstream.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package ferstream

import (
"fmt"
"time"

"github.com/kumparan/go-utils"
Expand Down Expand Up @@ -196,7 +197,7 @@ func NewNATSConnection(NATSJSHost string, clients []JetStreamRegistrar, natsOpts
return
}

logrus.Infof("NATS got reconnected to %q\n", nc.ConnectedUrl())
fmt.Printf("NATS got reconnected to %q\n", nc.ConnectedUrl())
}),
nats.ClosedHandler(func(nc *nats.Conn) {
logrus.Errorf("NATS connection closed. reason: %q\n", nc.LastError())
Expand Down

0 comments on commit b54d146

Please sign in to comment.