X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Fusecases%2Fodusliceassurance%2Fgoversion%2Finternal%2Fsliceassurance%2Fapp.go;h=4266508ac216660d2b7baf9e1970fc8cca4cf6d7;hb=refs%2Fchanges%2F09%2F7709%2F3;hp=7dc84b1fc8a309601c2a36fe8c6bfa37a8a4b7cd;hpb=da4ae7fc3df3c105fba7711c366d23bfbdd1e02c;p=nonrtric.git diff --git a/test/usecases/odusliceassurance/goversion/internal/sliceassurance/app.go b/test/usecases/odusliceassurance/goversion/internal/sliceassurance/app.go index 7dc84b1f..4266508a 100644 --- a/test/usecases/odusliceassurance/goversion/internal/sliceassurance/app.go +++ b/test/usecases/odusliceassurance/goversion/internal/sliceassurance/app.go @@ -39,7 +39,7 @@ const ( ) type App struct { - client restclient.HTTPClient + client *restclient.Client metricsPolicies *structures.SliceAssuranceMeas } @@ -69,9 +69,8 @@ func (a *App) Run(topic string, pollTime int) { func (a *App) getMessagesFromDmaap(url string) { var stdMessage messages.StdDefinedMessage - a.client.Get(url, &stdMessage) - log.Infof("Polling new messages from DmaapMR: %v", stdMessage) + log.Infof("Polling new messages from DmaapMR") for _, meas := range stdMessage.GetMeasurements() { //Create sliceMetric and check if metric exist and update existing one or create new one if _, err := a.metricsPolicies.AddOrUpdateMetric(meas); err != nil {