diff --git a/worker/types/worker.go b/worker/types/worker.go
index 5a964f2..ba396aa 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