diff options
Diffstat (limited to 'worker')
| -rw-r--r-- | worker/types/worker.go | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/worker/types/worker.go b/worker/types/worker.go index 5a964f2f..ba396aa3 100644 --- a/worker/types/worker.go +++ b/worker/types/worker.go @@ -64,10 +64,7 @@ func (worker *Worker) PostMessage(msg WorkerMessage, } else { logging.Debugf("PostMessage %T", msg) } - // This one needs to be in a separate goroutine to prevent deadlocks - go func() { - worker.Messages <- msg - }() + worker.Messages <- msg if cb != nil { worker.messageCallbacks[msg.getId()] = cb |