X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dmaap-mediator-producer%2Fstub%2Fconsumer%2Fconsumerstub.go;h=4260cae12b2de6e72c9cbe48a644205856c0c041;hb=5feecd881172a3b22041d35443c1f946e7d5f63e;hp=03e67c02591fb373204b73c6cce8795c2deabe50;hpb=6e0d5846a1f6d938605a4afa7f392d97ac2ba8bc;p=nonrtric.git

diff --git a/dmaap-mediator-producer/stub/consumer/consumerstub.go b/dmaap-mediator-producer/stub/consumer/consumerstub.go
index 03e67c02..4260cae1 100644
--- a/dmaap-mediator-producer/stub/consumer/consumerstub.go
+++ b/dmaap-mediator-producer/stub/consumer/consumerstub.go
@@ -43,8 +43,8 @@ func main() {
 
 	registerJob(*port)
 
-	fmt.Print("Starting consumer on port: ", *port)
-	http.ListenAndServe(fmt.Sprintf(":%v", *port), nil)
+	fmt.Println("Starting consumer on port: ", *port)
+	fmt.Println(http.ListenAndServe(fmt.Sprintf(":%v", *port), nil))
 }
 
 func registerJob(port int) {
@@ -59,11 +59,11 @@ func registerJob(port int) {
 		InfoTypeId:    "STD_Fault_Messages",
 		JobDefinition: "{}",
 	}
-	fmt.Print("Registering consumer: ", jobInfo)
+	fmt.Println("Registering consumer: ", jobInfo)
 	body, _ := json.Marshal(jobInfo)
 	putErr := restclient.Put(fmt.Sprintf("http://localhost:8083/data-consumer/v1/info-jobs/job%v", port), body, &httpClient)
 	if putErr != nil {
-		fmt.Printf("Unable to register consumer: %v", putErr)
+		fmt.Println("Unable to register consumer: ", putErr)
 	}
 }