src/TreeHouse/WorkerBundle/QueueExecutor.php 1 location
|
@@ 182-194 (lines=13) @@
|
| 179 |
|
* |
| 180 |
|
* @return OptionsResolver |
| 181 |
|
*/ |
| 182 |
|
protected function getPayloadResolver(ExecutorInterface $executor) |
| 183 |
|
{ |
| 184 |
|
$key = $executor->getName(); |
| 185 |
|
|
| 186 |
|
if (!array_key_exists($key, $this->resolvers)) { |
| 187 |
|
$resolver = new OptionsResolver(); |
| 188 |
|
$executor->configurePayload($resolver); |
| 189 |
|
|
| 190 |
|
$this->resolvers[$key] = $resolver; |
| 191 |
|
} |
| 192 |
|
|
| 193 |
|
return $this->resolvers[$key]; |
| 194 |
|
} |
| 195 |
|
|
| 196 |
|
/** |
| 197 |
|
* @param int $jobId |
src/TreeHouse/WorkerBundle/QueueManager.php 1 location
|
@@ 636-648 (lines=13) @@
|
| 633 |
|
* |
| 634 |
|
* @return OptionsResolver |
| 635 |
|
*/ |
| 636 |
|
protected function getPayloadResolver(ExecutorInterface $executor) |
| 637 |
|
{ |
| 638 |
|
$key = $executor->getName(); |
| 639 |
|
|
| 640 |
|
if (!array_key_exists($key, $this->resolvers)) { |
| 641 |
|
$resolver = new OptionsResolver(); |
| 642 |
|
$executor->configurePayload($resolver); |
| 643 |
|
|
| 644 |
|
$this->resolvers[$key] = $resolver; |
| 645 |
|
} |
| 646 |
|
|
| 647 |
|
return $this->resolvers[$key]; |
| 648 |
|
} |
| 649 |
|
|
| 650 |
|
/** |
| 651 |
|
* @param int $jobId |