X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dmaap-mediator-producer%2Fmain.go;h=d38496ff2208307efaff394a6542fbe29aeaae7e;hb=a77cd650f99b29be6c53a690157529e7e158d70e;hp=240bdbd50cb3d5217a202cc21daff89c87118aa5;hpb=cce95ff706e7b7d703b0bf1cfa6ce855cc2d9b68;p=nonrtric.git

diff --git a/dmaap-mediator-producer/main.go b/dmaap-mediator-producer/main.go
index 240bdbd5..d38496ff 100644
--- a/dmaap-mediator-producer/main.go
+++ b/dmaap-mediator-producer/main.go
@@ -39,8 +39,11 @@ func init() {
 	}
 
 	log.Debug("Initializing DMaaP Mediator Producer")
-	if configuration.JobResultUri == "" {
-		log.Fatal("Missing JOB_RESULT_URI")
+	if configuration.InfoJobCallbackUrl == "" {
+		log.Fatal("Missing INFO_JOB_CALLBACK_URL")
+	}
+	if configuration.InfoProducerSupervisionCallbackUrl == "" {
+		log.Fatal("Missing INFO_PRODUCER_SUPERVISION_CALLBACK_URL")
 	}
 
 	registrator := config.NewRegistratorImpl(configuration.InfoCoordinatorAddress)
@@ -51,6 +54,14 @@ func init() {
 	} else {
 		log.Fatalf("Unable to get types to register due to: %v", err)
 	}
+	producer := config.ProducerRegistrationInfo{
+		InfoProducerSupervisionCallbackUrl: configuration.InfoProducerSupervisionCallbackUrl,
+		SupportedInfoTypes:                 jobtypes.GetSupportedTypes(),
+		InfoJobCallbackUrl:                 configuration.InfoJobCallbackUrl,
+	}
+	if err := registrator.RegisterProducer("DMaaP_Mediator_Producer", &producer); err != nil {
+		log.Fatalf("Unable to register producer due to: %v", err)
+	}
 }
 
 func main() {