mirror of
https://github.com/idanoo/php-resque.git
synced 2024-11-24 17:25:13 +00:00
commit
cf187fae52
@ -96,7 +96,7 @@ if(!empty($PREFIX)) {
|
|||||||
if($count > 1) {
|
if($count > 1) {
|
||||||
for($i = 0; $i < $count; ++$i) {
|
for($i = 0; $i < $count; ++$i) {
|
||||||
$pid = Resque::fork();
|
$pid = Resque::fork();
|
||||||
if($pid === false || pid === -1) {
|
if($pid === false || $pid === -1) {
|
||||||
$logger->log(Psr\Log\LogLevel::EMERGENCY, 'Could not fork worker {count}', array('count' => $i));
|
$logger->log(Psr\Log\LogLevel::EMERGENCY, 'Could not fork worker {count}', array('count' => $i));
|
||||||
die();
|
die();
|
||||||
}
|
}
|
||||||
@ -126,4 +126,4 @@ else {
|
|||||||
$logger->log(Psr\Log\LogLevel::NOTICE, 'Starting worker {worker}', array('worker' => $worker));
|
$logger->log(Psr\Log\LogLevel::NOTICE, 'Starting worker {worker}', array('worker' => $worker));
|
||||||
$worker->work($interval, $BLOCKING);
|
$worker->work($interval, $BLOCKING);
|
||||||
}
|
}
|
||||||
?>
|
?>
|
||||||
|
Loading…
Reference in New Issue
Block a user