diff --git a/queue/handler/routes.go b/queue/handler/routes.go index 15bc8f1..b4ead3c 100644 --- a/queue/handler/routes.go +++ b/queue/handler/routes.go @@ -39,4 +39,7 @@ func RegisterHandlers(mux *asynq.ServeMux, serverCtx *svc.ServiceContext) { // ScheduledBatchSendEmail mux.Handle(types.ScheduledBatchSendEmail, emailLogic.NewBatchEmailLogic(serverCtx)) + + // ScheduledTrafficStat + mux.Handle(types.SchedulerTrafficStat, traffic.NewStatLogic(serverCtx)) }