Skip to content
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.

Commit ed707fe

Browse files
committedSep 27, 2018
Update enqueue architecture. Get rid of meta (queue|topic), rely one routes.
1 parent eca10ef commit ed707fe

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

46 files changed

+1489
-1423
lines changed
 

‎pkg/enqueue/Client/ArrayProcessorRegistry.php

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -19,19 +19,12 @@ public function __construct(array $processors = [])
1919
$this->processors = $processors;
2020
}
2121

22-
/**
23-
* @param string $name
24-
* @param PsrProcessor $processor
25-
*/
26-
public function add($name, PsrProcessor $processor)
22+
public function add(string $name, PsrProcessor $processor): void
2723
{
2824
$this->processors[$name] = $processor;
2925
}
3026

31-
/**
32-
* {@inheritdoc}
33-
*/
34-
public function get($processorName)
27+
public function get(string $processorName): PsrProcessor
3528
{
3629
if (false == isset($this->processors[$processorName])) {
3730
throw new \LogicException(sprintf('Processor was not found. processorName: "%s"', $processorName));

‎pkg/enqueue/Client/ChainExtension.php

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@ final class ChainExtension implements ExtensionInterface
1414
*/
1515
public function __construct(array $extensions)
1616
{
17+
$this->extensions = [];
1718
array_walk($extensions, function (ExtensionInterface $extension) {
1819
$this->extensions[] = $extension;
1920
});

0 commit comments

Comments
 (0)
Please sign in to comment.