feat: 添加deleteItemKq (#15)

CloudStriver · Feb 17, 2024 · 7dfaaff · 7dfaaff
1 parent 37ac8dd
commit 7dfaaff
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/app/config/config.go b/app/config/config.go
@@ -12,7 +12,7 @@ type Config struct {
 	DeleteNotificationsConf kq.KqConf
 	CreateItemConf          kq.KqConf
 	UpdateItemConf          kq.KqConf
-	//DeleteItemConf          kq.KqConf
-	CreateFeedBackConf kq.KqConf
-	EnvHeader          string
+	DeleteItemConf          kq.KqConf
+	CreateFeedBackConf      kq.KqConf
+	EnvHeader               string
 }
diff --git a/app/listen/kqMqs.go b/app/listen/kqMqs.go
@@ -17,5 +17,6 @@ func KqMqs(c config.Config, ctx context.Context, svcContext *svc.ServiceContext)
 		kq.MustNewQueue(c.CreateItemConf, mq.NewCreateItemMq(ctx, svcContext)),
 		kq.MustNewQueue(c.UpdateItemConf, mq.NewUpdateItemMq(ctx, svcContext)),
 		kq.MustNewQueue(c.CreateFeedBackConf, mq.NewCreateFeedBackMq(ctx, svcContext)),
+		kq.MustNewQueue(c.DeleteItemConf, mq.NewDeleteItemMq(ctx, svcContext)),
 	}
 }