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)), } }