X-Git-Url: https://gerrit.akraino.org/r/gitweb?a=blobdiff_plain;f=mep%2Fmepserver%2Fmp1%2Fplan_get_subsribes.go;h=06f04aa496dd3880b6e9dddc745355f6b92834ee;hb=5d2f02323cb42ca777653677359dd7898eb1ac07;hp=cf3477015d0c091dbb30959913204a7691650946;hpb=8be78342e1ce130fe925c4939972af5b1759293e;p=ealt-edge.git

diff --git a/mep/mepserver/mp1/plan_get_subsribes.go b/mep/mepserver/mp1/plan_get_subsribes.go
index cf34770..06f04aa 100644
--- a/mep/mepserver/mp1/plan_get_subsribes.go
+++ b/mep/mepserver/mp1/plan_get_subsribes.go
@@ -47,6 +47,7 @@ func (t *GetSubscribes) OnRequest(data string) workspace.TaskCode {
 	opts := []registry.PluginOp{
 		registry.OpGet(registry.WithStrKey("/cse-sr/etsi/subscribe/"+appInstanceId), registry.WithPrefix()),
 	}
+
 	resp, err := backend.Registry().TxnWithCmp(context.Background(), opts, nil, nil)
 	if err != nil {
 		log.Errorf(err, "get subscription from etcd failed")
@@ -63,6 +64,7 @@ func (t *GetSubscribes) OnRequest(data string) workspace.TaskCode {
 		t.SetFirstErrorCode(SubscriptionNotFound, "get subscription failed, subscription not exist")
 		return workspace.TaskFinish
 	}
+
 	subs := make([]*models.SerAvailabilityNotificationSubscription, 0, len(values))
 	for _, val := range values {
 		sub := &models.SerAvailabilityNotificationSubscription{}
@@ -73,6 +75,7 @@ func (t *GetSubscribes) OnRequest(data string) workspace.TaskCode {
 		}
 		subs = append(subs, sub)
 	}
+
 	t.HttpRsp = subs
 	return workspace.TaskFinish
 }