X-Git-Url: https://gerrit.akraino.org/r/gitweb?a=blobdiff_plain;f=mep%2Fmepserver%2Fmp1%2Fplan_subscribe_app.go;h=b2f4169d1dace04030602a7f9dbbeef7d3648df5;hb=8be78342e1ce130fe925c4939972af5b1759293e;hp=c93ab272a807656f9e3d4722cdb474ccd3bde05a;hpb=ec7a1edb742d33ed1775ea50306ce22a79e542e8;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 {