X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dmaap-mediator-producer%2Fmain.go;h=194ed7507a122fa74ea7ea21136128cf84b4e45f;hb=46a0fd717e5f49ebae6cb2c4fbcf54f0e329dc86;hp=74f4edfbe90b1a74859c2a6f72941d410188372f;hpb=d0c7f9207203ce9a502fc15c09f9938eebfd44f7;p=nonrtric.git diff --git a/dmaap-mediator-producer/main.go b/dmaap-mediator-producer/main.go index 74f4edfb..194ed750 100644 --- a/dmaap-mediator-producer/main.go +++ b/dmaap-mediator-producer/main.go @@ -60,7 +60,7 @@ func main() { if err := registerTypesAndProducer(jobsManager, configuration.InfoCoordinatorAddress, callbackAddress, retryClient); err != nil { log.Fatalf("Stopping producer due to: %v", err) } - jobsManager.StartJobs() + jobsManager.StartJobsForAllTypes() log.Debug("Starting DMaaP Mediator Producer") go func() {