treehouselabs /
worker-bundle
| @@ 374-385 (lines=12) @@ | ||
| 371 | * |
|
| 372 | * @return int The number of kicked jobs |
|
| 373 | */ |
|
| 374 | public function kick($action, $max) |
|
| 375 | { |
|
| 376 | $this->pheanstalk->useTube($action); |
|
| 377 | ||
| 378 | $kicked = $this->pheanstalk->kick($max); |
|
| 379 | ||
| 380 | $this->logger->debug( |
|
| 381 | sprintf('Kicked %d "%s" jobs back onto the ready queue', $kicked, $action) |
|
| 382 | ); |
|
| 383 | ||
| 384 | return $kicked; |
|
| 385 | } |
|
| 386 | ||
| 387 | /** |
|
| 388 | * @param Job $job |
|
| @@ 455-466 (lines=12) @@ | ||
| 452 | * |
|
| 453 | * @return int The number of kicked jobs |
|
| 454 | */ |
|
| 455 | public function kick($action, $max) |
|
| 456 | { |
|
| 457 | $this->pheanstalk->useTube($action); |
|
| 458 | ||
| 459 | $kicked = $this->pheanstalk->kick($max); |
|
| 460 | ||
| 461 | $this->logger->debug( |
|
| 462 | sprintf('Kicked %d "%s" jobs back onto the ready queue', $kicked, $action) |
|
| 463 | ); |
|
| 464 | ||
| 465 | return $kicked; |
|
| 466 | } |
|
| 467 | ||
| 468 | /** |
|
| 469 | * @param Job $job |
|
