X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dmaap-mediator-producer%2Fmain.go;h=15207ec713af51ab0385c96f96974c2677bf5b00;hb=refs%2Fchanges%2F28%2F6828%2F1;hp=47e12e9af0905d73090ce70161386a9ce6938813;hpb=82378715d387362e97a064665a2467c587afdeed;p=nonrtric.git diff --git a/dmaap-mediator-producer/main.go b/dmaap-mediator-producer/main.go index 47e12e9a..15207ec7 100644 --- a/dmaap-mediator-producer/main.go +++ b/dmaap-mediator-producer/main.go @@ -22,6 +22,7 @@ package main import ( "fmt" + "net/http" "sync" log "github.com/sirupsen/logrus" @@ -31,8 +32,7 @@ import ( ) var configuration *config.Config -var supervisionCallbackAddress string -var jobInfoCallbackAddress string +var callbackAddress string func init() { configuration = config.New() @@ -43,15 +43,10 @@ func init() { } log.Debug("Initializing DMaaP Mediator Producer") - if configuration.InfoProducerSupervisionCallbackHost == "" { + if configuration.InfoProducerHost == "" { log.Fatal("Missing INFO_PRODUCER_SUPERVISION_CALLBACK_HOST") } - supervisionCallbackAddress = fmt.Sprintf("%v:%v", configuration.InfoProducerSupervisionCallbackHost, configuration.InfoProducerSupervisionCallbackPort) - - if configuration.InfoJobCallbackHost == "" { - log.Fatal("Missing INFO_JOB_CALLBACK_HOST") - } - jobInfoCallbackAddress = fmt.Sprintf("%v:%v", configuration.InfoJobCallbackHost, configuration.InfoJobCallbackPort) + callbackAddress = fmt.Sprintf("%v:%v", configuration.InfoProducerHost, configuration.InfoProducerPort) registrator := config.NewRegistratorImpl(configuration.InfoCoordinatorAddress) if types, err := jobs.GetTypes(); err == nil { @@ -62,9 +57,9 @@ func init() { log.Fatalf("Unable to get types to register due to: %v", err) } producer := config.ProducerRegistrationInfo{ - InfoProducerSupervisionCallbackUrl: supervisionCallbackAddress, + InfoProducerSupervisionCallbackUrl: callbackAddress + server.StatusPath, SupportedInfoTypes: jobs.GetSupportedTypes(), - InfoJobCallbackUrl: jobInfoCallbackAddress, + InfoJobCallbackUrl: callbackAddress + server.AddJobPath, } if err := registrator.RegisterProducer("DMaaP_Mediator_Producer", &producer); err != nil { log.Fatalf("Unable to register producer due to: %v", err) @@ -75,19 +70,13 @@ func main() { log.Debug("Starting DMaaP Mediator Producer") wg := new(sync.WaitGroup) - // add two goroutines to `wg` WaitGroup, one for each avilable server - wg.Add(3) - - log.Debugf("Starting status callback server at port %v", configuration.InfoProducerSupervisionCallbackPort) - go func() { - server := server.CreateServer(configuration.InfoProducerSupervisionCallbackPort, server.StatusHandler) - log.Warn(server.ListenAndServe()) - wg.Done() - }() + // add two goroutines to `wg` WaitGroup, one for each running go routine + wg.Add(2) + log.Debugf("Starting callback server at port %v", configuration.InfoProducerPort) go func() { - server := server.CreateServer(configuration.InfoJobCallbackPort, server.CreateInfoJobHandler) - log.Warn(server.ListenAndServe()) + r := server.NewRouter() + log.Warn(http.ListenAndServe(fmt.Sprintf(":%v", configuration.InfoProducerPort), r)) wg.Done() }()