diff options
Diffstat (limited to 'app/app.go')
| -rw-r--r-- | app/app.go | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/app/app.go b/app/app.go index 511a464be..1c0d56a3c 100644 --- a/app/app.go +++ b/app/app.go @@ -50,6 +50,8 @@ type App struct { Hubs []*Hub HubsStopCheckingForDeadlock chan bool + PushNotificationsHub PushNotificationsHub + Jobs *jobs.JobServer AccountMigration einterfaces.AccountMigrationInterface @@ -128,6 +130,9 @@ func New(options ...Option) (outApp *App, outErr error) { app.HTTPService = MakeHTTPService(app) + app.CreatePushNotificationsHub() + app.StartPushNotificationsHubWorkers() + defer func() { if outErr != nil { app.Shutdown() @@ -276,6 +281,7 @@ func (a *App) Shutdown() { a.StopServer() a.HubStop() + a.StopPushNotificationsHubWorkers() a.ShutDownPlugins() a.WaitForGoroutines() |