|
@@ -59,10 +59,10 @@ func NewFirebaseMessageServer(repos *repositories.Repositories) *FirebaseMessage
|
|
|
|
|
|
firebaseMessageServer := &FirebaseMessageServer{app: app, client: client, repos: repos}
|
|
|
|
|
|
- // c := cron.New()
|
|
|
- _ = cron.New()
|
|
|
- // c.AddFunc("@every 5s", func() { firebaseMessageServer.queueRun(ctx) })
|
|
|
- // c.Start()
|
|
|
+ c := cron.New()
|
|
|
+ //_ = cron.New()
|
|
|
+ c.AddFunc("@every 5s", func() { firebaseMessageServer.queueRun(ctx) })
|
|
|
+ c.Start()
|
|
|
|
|
|
return firebaseMessageServer
|
|
|
}
|