Merge pull request #99 from alpacahq/fix/set-poly

apply polygon api settings
alpacahq · Jun 26, 2018 · 8c7d63b · 8c7d63b
2 parents 5c13467 + ef8f7a2
commit 8c7d63b
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/contrib/polygon/polygon.go b/contrib/polygon/polygon.go
@@ -57,6 +57,14 @@ func NewBgWorker(conf map[string]interface{}) (bgworker.BgWorker, error) {
 func (pf *PolygonFetcher) Run() {
 	api.SetAPIKey(pf.config.APIKey)
 
+	if pf.config.BaseURL != "" {
+		api.SetBaseURL(pf.config.BaseURL)
+	}
+
+	if pf.config.NatsServers != "" {
+		api.SetNatsServers(pf.config.NatsServers)
+	}
+
 	go pf.workBackfill()
 
 	if err := api.Stream(pf.streamHandler, pf.config.Symbols); err != nil {