X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dmaap-mediator-producer%2Fmain.go;h=194ed7507a122fa74ea7ea21136128cf84b4e45f;hb=242299199382ec3fd7d514dde2eb607086a6a46e;hp=74f4edfbe90b1a74859c2a6f72941d410188372f;hpb=968b89731a192c2ee3f3393d00519879ad89ce56;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() {