trigger connection establish error

gojek · Aug 8, 2023 · 27e4ff6 · 27e4ff6
1 parent 33ef257
commit 27e4ff6
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/client_resolver.go b/client_resolver.go
@@ -62,6 +62,10 @@ func (c *Client) newClient(addrs []TCPAddress, attempt int) mqtt.Client {
 
 	if err := t.Error(); err != nil {
 		// TODO: add retry backoff or use ExponentialStartStrategy utility
+		if c.options.onConnectionLostHandler != nil {
+			c.options.onConnectionLostHandler(err)
+		}
+
 		return c.newClient(addrs, attempt+1)
 	}