diff --git a/handlers/misttriggers/trigger_broker.go b/handlers/misttriggers/trigger_broker.go index b2985f096..ff40cc7b8 100644 --- a/handlers/misttriggers/trigger_broker.go +++ b/handlers/misttriggers/trigger_broker.go @@ -3,10 +3,10 @@ package misttriggers import ( "context" "fmt" - "github.com/livepeer/catalyst-api/clients" "sync" "github.com/golang/glog" + "github.com/livepeer/catalyst-api/clients" "golang.org/x/sync/errgroup" ) diff --git a/main.go b/main.go index eef80a348..0d5a833d6 100644 --- a/main.go +++ b/main.go @@ -319,7 +319,7 @@ func main() { if cli.IsClusterMode() { // Configure Mist Triggers if cli.MistEnabled && cli.MistTriggerSetup { - mistTriggerHandlerEndpoint := fmt.Sprintf("%s/api/mist/trigger", catalystApiURL) + mistTriggerHandlerEndpoint := fmt.Sprintf("%s/api/mist/trigger", cli.OwnInternalURL()) err := broker.SetupMistTriggers(mist, mistTriggerHandlerEndpoint) if err != nil { glog.Error("catalyst-api was unable to communicate with MistServer to set up its triggers.")