X-Git-Url: https://gerrit.akraino.org/r/gitweb?a=blobdiff_plain;f=mep%2Fmepserver%2Fmp1%2Fplan_subscribe_app.go;h=b2f4169d1dace04030602a7f9dbbeef7d3648df5;hb=b53813aee440d6c0a936a2827e5c304cf60d8be1;hp=c93ab272a807656f9e3d4722cdb474ccd3bde05a;hpb=f60c4a6d3d28aa32d7638a89ec2c3384b4466cb6;p=ealt-edge.git diff --git a/mep/mepserver/mp1/plan_subscribe_app.go b/mep/mepserver/mp1/plan_subscribe_app.go index c93ab27..b2f4169 100644 --- a/mep/mepserver/mp1/plan_subscribe_app.go +++ b/mep/mepserver/mp1/plan_subscribe_app.go @@ -44,6 +44,7 @@ type SubscribeIst struct { HttpRsp interface{} `json:"httpRsp,out"` } +//service subscription request func (t *SubscribeIst) OnRequest(data string) workspace.TaskCode { mp1SubscribeInfo, ok := t.RestBody.(*models.SerAvailabilityNotificationSubscription) @@ -63,7 +64,7 @@ func (t *SubscribeIst) OnRequest(data string) workspace.TaskCode { } opts := []registry.PluginOp{ registry.OpPut(registry.WithStrKey("/cse-sr/etsi/subscribe/"+appInstanceId+"/"+subscribeId), - registry.WithValue(subscribeJSON)), + registry.WithValue(subscribeJSON)), } _, resultErr := backend.Registry().TxnWithCmp(context.Background(), opts, nil, nil) if resultErr != nil {