- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for SetConnectionLostHandler (0.12 sec)
-
docs/bucket/notifications/README.md
fmt.Printf("Received a message: %s\n", string(m.Data)) }) } stanConnection, _ = stan.Connect("test-cluster", "test-client", stan.NatsURL("nats://yourusername:yoursecret@0.0.0.0:4222"), stan.SetConnectionLostHandler(func(c stan.Conn, _ error) { go func() { for { // Reconnect if the connection is lost. if stanConnection == nil || stanConnection.NatsConn() == nil || !stanConnection.NatsConn().IsConnected() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 84K bytes - Viewed (0)