X-Git-Url: https://gerrit.akraino.org/r/gitweb?a=blobdiff_plain;f=mep%2Fmepserver%2Fmp1%2Fplan_register_svc.go;h=ea5ebff241902ef22144578996ea8bd168435919;hb=a8f10d63cbb6acdc6f9d2f4fa5de3e2392bed6df;hp=fe68be1893edcf3d8d6e3b8cd56301e4a1fc8bec;hpb=5d2f02323cb42ca777653677359dd7898eb1ac07;p=ealt-edge.git diff --git a/mep/mepserver/mp1/plan_register_svc.go b/mep/mepserver/mp1/plan_register_svc.go index fe68be1..ea5ebff 100644 --- a/mep/mepserver/mp1/plan_register_svc.go +++ b/mep/mepserver/mp1/plan_register_svc.go @@ -163,6 +163,7 @@ type RegisterServiceInst struct { HttpRsp interface{} `json:"httpRsp,out"` } +//request service registry handling func (t *RegisterServiceInst) OnRequest(data string) workspace.TaskCode { serviceInfo, ok := t.RestBody.(*models.ServiceInfo) if !ok { @@ -173,6 +174,8 @@ func (t *RegisterServiceInst) OnRequest(data string) workspace.TaskCode { serviceInfo.ToRegisterInstance(req) req.Instance.ServiceId = t.ServiceId req.Instance.Properties["appInstanceId"] = t.AppInstanceId + + //Call service comb for instance register resp, err := core.InstanceAPI.Register(t.Ctx, req) if err != nil { log.Errorf(err, "RegisterInstance fail: %s", t.ServiceId)