X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Fusecases%2Foruclosedlooprecovery%2Fgoversion%2Fstub%2Fproducer%2Fproducerstub.go;h=e219e19d926834bdd1e0290486165003ea9298d3;hb=5b26de71a0aae08360a38477150551651a7ef734;hp=4af16cf552f50ae9bf6851e57ffe6e575f20643f;hpb=12ec4c639a5b2fefd9aebeb281ba0e8d824b1b47;p=nonrtric.git

diff --git a/test/usecases/oruclosedlooprecovery/goversion/stub/producer/producerstub.go b/test/usecases/oruclosedlooprecovery/goversion/stub/producer/producerstub.go
index 4af16cf5..e219e19d 100644
--- a/test/usecases/oruclosedlooprecovery/goversion/stub/producer/producerstub.go
+++ b/test/usecases/oruclosedlooprecovery/goversion/stub/producer/producerstub.go
@@ -52,7 +52,7 @@ func createJobHandler(w http.ResponseWriter, r *http.Request) {
 
 	started = true
 	fmt.Println("Start pushing messages for job: ", id)
-	startPushingMessages()
+	go startPushingMessages()
 }
 
 func deleteJobHandler(w http.ResponseWriter, r *http.Request) {