wwweww
16 lines
453 B
Go
16 lines
453 B
Go
package consumer
|
|
|
|
import (
|
|
"context"
|
|
"juwan-backend/app/email/mq/internal/config"
|
|
"juwan-backend/app/email/mq/internal/logic"
|
|
"juwan-backend/app/email/mq/internal/svc"
|
|
|
|
"github.com/zeromicro/go-queue/kq"
|
|
"github.com/zeromicro/go-zero/core/service"
|
|
)
|
|
|
|
func Kqs(ctx context.Context, c config.Config, svcCtx *svc.ServiceContext) []service.Service {
|
|
return []service.Service{kq.MustNewQueue(c.Kmq, logic.NewSendVerificationCodeMq(ctx, c, svcCtx))}
|
|
}
|