X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=cmd%2Fvesmgr%2FsubscribexAPPNotifications.go;h=c87a0a3e8bcc5ba97afb79e6aa4f940a2116727d;hb=267b90952fcc7ce831d21631692543d27c1c5f76;hp=1d3cc22e4de6759f3ad298b3b7fa37c8e59fd956;hpb=fc77ebb24a8627ccfb18edd8b5dbc038da475eab;p=ric-plt%2Fvespamgr.git diff --git a/cmd/vesmgr/subscribexAPPNotifications.go b/cmd/vesmgr/subscribexAPPNotifications.go index 1d3cc22..c87a0a3 100644 --- a/cmd/vesmgr/subscribexAPPNotifications.go +++ b/cmd/vesmgr/subscribexAPPNotifications.go @@ -13,6 +13,10 @@ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. + * + * This source code is part of the near-RT RIC (RAN Intelligent Controller) + * platform project (RICP). + * */ package main @@ -34,7 +38,7 @@ var errPostingFailed = errors.New("Posting subscriptions failed") var errWrongStatusCode = errors.New("Wrong subscriptions response StatusCode") func subscribexAppNotifications(targetURL string, subscriptions chan subscriptionNotification, timeout time.Duration, subsURL string) { - requestBody := []byte(fmt.Sprintf(`{"maxRetries": 5, "retryTimer": 5, "eventType":"all", "targetUrl": "%v"}`, targetURL)) + requestBody := []byte(fmt.Sprintf(`{"Data": {"maxRetries": 5, "retryTimer": 5, "eventType":"all", "targetUrl": "%v"}}`, targetURL)) req, err := http.NewRequest("POST", subsURL, bytes.NewBuffer(requestBody)) if err != nil { logger.Error("Setting NewRequest failed: %s", err) @@ -61,7 +65,7 @@ func subscribexAppNotifications(targetURL string, subscriptions chan subscriptio func subscribexAppNotificationsClientDo(req *http.Request, client *http.Client) (string, error) { resp, err := client.Do(req) if err != nil { - logger.Error("Posting subscriptions failed: %s", err) + logger.Error("Posting subscriptions failed: %v", err) return "", errPostingFailed } defer resp.Body.Close()