diff options
Diffstat (limited to 'internal/processing/processor.go')
-rw-r--r-- | internal/processing/processor.go | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/internal/processing/processor.go b/internal/processing/processor.go index b7d42ffeb..f464a08b4 100644 --- a/internal/processing/processor.go +++ b/internal/processing/processor.go @@ -351,6 +351,11 @@ func (p *processor) Start() error { return err } + // Start status timelines + if err := p.statusTimelines.Start(); err != nil { + return err + } + return nil } @@ -359,8 +364,14 @@ func (p *processor) Stop() error { if err := p.clientWorker.Stop(); err != nil { return err } + if err := p.fedWorker.Stop(); err != nil { return err } + + if err := p.statusTimelines.Stop(); err != nil { + return err + } + return nil } |