diff --git a/src/Backends/Swoole.php b/src/Backends/Swoole.php index 34eb894b8..6eb268c8d 100644 --- a/src/Backends/Swoole.php +++ b/src/Backends/Swoole.php @@ -98,7 +98,10 @@ function (Process $worker) use ($maxMessageLength, $queueItem) { true, ); - $workerProcess->setAffinity([$currentCpu]); + if (method_exists($workerProcess, 'setAffinity')) { + $workerProcess->setAffinity([$currentCpu]); + } + $workerProcess->setBlocking(false); $workerProcess->start();