From 7dfaaff393562a764ae5f1ee55ec92243c611535 Mon Sep 17 00:00:00 2001 From: Lansong <62054128+Lansongxx@users.noreply.github.com> Date: Sat, 17 Feb 2024 10:49:00 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=B7=BB=E5=8A=A0deleteItemKq=20(#15)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/config/config.go | 6 +++--- app/listen/kqMqs.go | 1 + 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/app/config/config.go b/app/config/config.go index f319af8..8cdb497 100644 --- 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 index 1cef56c..77d61c2 100644 --- 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)), } }