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 |