Skip to content

Commit 21b3ee0

Browse files
authored
fix: improving nats debugging. Need to update the Health Checker (#71)
Co-authored-by: Dimy Jeannot <>
1 parent 4ce39b0 commit 21b3ee0

File tree

1 file changed

+10
-9
lines changed

1 file changed

+10
-9
lines changed

go/oeco-sdk/v2beta/bindings/nats/binding.go

Lines changed: 10 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -127,17 +127,18 @@ func (b *Binding) Bind(_ context.Context, bindings *sdkv2betalib.Bindings) *sdkv
127127
}
128128

129129
natsOptions = append(natsOptions, nats.SetCustomDialer(nebulav1.Bound.MeshSocket))
130-
natsOptions = append(natsOptions, nats.DisconnectErrHandler(func(_ *nats.Conn, err error) {
131-
apexlog.Info("Disconnected due to: " + err.Error())
132-
}))
133-
natsOptions = append(natsOptions, nats.ReconnectHandler(func(nc *nats.Conn) {
134-
apexlog.Info("Reconnected to " + nc.ConnectedUrl())
135-
}))
136-
natsOptions = append(natsOptions, nats.ClosedHandler(func(_ *nats.Conn) {
137-
apexlog.Info("Connection closed.")
138-
}))
139130
}
140131

132+
natsOptions = append(natsOptions, nats.DisconnectErrHandler(func(_ *nats.Conn, err error) {
133+
apexlog.Info("Disconnected due to: " + err.Error())
134+
}))
135+
natsOptions = append(natsOptions, nats.ReconnectHandler(func(nc *nats.Conn) {
136+
apexlog.Info("Reconnected to " + nc.ConnectedUrl())
137+
}))
138+
natsOptions = append(natsOptions, nats.ClosedHandler(func(_ *nats.Conn) {
139+
apexlog.Info("Connection closed.")
140+
}))
141+
141142
_nats, err := nats.Connect(servers, natsOptions...)
142143
if err != nil {
143144
fmt.Println(err.Error())

0 commit comments

Comments
 (0)