APIGOV-21446 - Fix for setting single entry option on stream if confi…

…g url is set (#390)
Axway · Apr 12, 2022 · dfe8a5e · dfe8a5e
1 parent 6920539
commit dfe8a5e
Showing 1 changed file with 9 additions and 6 deletions.
diff --git a/pkg/agent/stream/client.go b/pkg/agent/stream/client.go
@@ -163,17 +163,20 @@ func NewStreamer(
 		TokenGetter: getToken.GetToken,
 	}
 	sequenceManager := newAgentSequenceManager(cacheManager, wt.Name)
-	singleEntryAddr := ""
-	singleEntryURL, err := url.Parse(cfg.GetSingleURL())
-	if err == nil {
-		singleEntryAddr = util.ParseAddr(singleEntryURL)
-	}
+
 	watchOpts := []wm.Option{
 		wm.WithLogger(logrus.NewEntry(log.Get())),
 		wm.WithSyncEvents(sequenceManager),
 		wm.WithTLSConfig(cfg.GetTLSConfig().BuildTLSConfig()),
 		wm.WithProxy(cfg.GetProxyURL()),
-		wm.WithSingleEntryAddr(singleEntryAddr),
+	}
+
+	if cfg.GetSingleURL() != "" {
+		singleEntryURL, err := url.Parse(cfg.GetSingleURL())
+		if err == nil {
+			singleEntryAddr := util.ParseAddr(singleEntryURL)
+			wm.WithSingleEntryAddr(singleEntryAddr)
+		}
 	}
 
 	return &streamer{