add max reconnects

amagimedia · Jun 25, 2020 · 1fcca8a · 1fcca8a
1 parent 26c693e
commit 1fcca8a
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/protocols/sub/pubnub.go b/protocols/sub/pubnub.go
@@ -264,6 +264,9 @@ func pubnubConnect(cfg pubnubConfig) (jmsg.RawPubnubClient, error) {
 	config := pubnub.NewConfig()
 	config.SubscribeKey = cfg.SubscribeKey
 	config.PublishKey = cfg.PublishKey
+	config.SubscribeRequestTimeout = 30
+	config.MaximumReconnectionRetries = 2
+
 	if cfg.SecretKey != "" {
 		config.SecretKey = cfg.SecretKey
 	}