diff options
Diffstat (limited to 'worker/mbox')
| -rw-r--r-- | worker/mbox/worker.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/worker/mbox/worker.go b/worker/mbox/worker.go index 0e6c64d1..5034f66d 100644 --- a/worker/mbox/worker.go +++ b/worker/mbox/worker.go @@ -374,7 +374,7 @@ func (w *mboxWorker) handleMessage(msg types.WorkerMessage) error { } func (w *mboxWorker) Run() { - for msg := range w.worker.Actions { + for msg := range w.worker.Actions() { msg = w.worker.ProcessAction(msg) if err := w.handleMessage(msg); errors.Is(err, errUnsupported) { w.worker.PostMessage(&types.Unsupported{ |