Signed-off-by: khemendra kumar <khemendra.kumar@huawei.com>
Change-Id: I4471ac43619ec892c5dcb48b08b0b992b522bc77
HttpRsp interface{} `json:"httpRsp,out"`
}
HttpRsp interface{} `json:"httpRsp,out"`
}
+//service subscription request
func (t *SubscribeIst) OnRequest(data string) workspace.TaskCode {
mp1SubscribeInfo, ok := t.RestBody.(*models.SerAvailabilityNotificationSubscription)
func (t *SubscribeIst) OnRequest(data string) workspace.TaskCode {
mp1SubscribeInfo, ok := t.RestBody.(*models.SerAvailabilityNotificationSubscription)
}
opts := []registry.PluginOp{
registry.OpPut(registry.WithStrKey("/cse-sr/etsi/subscribe/"+appInstanceId+"/"+subscribeId),
}
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 {
}
_, resultErr := backend.Registry().TxnWithCmp(context.Background(), opts, nil, nil)
if resultErr != nil {