| Conditions | 2 |
| Paths | 2 |
| Total Lines | 19 |
| Code Lines | 11 |
| Lines | 0 |
| Ratio | 0 % |
| Tests | 11 |
| CRAP Score | 2 |
| Changes | 0 | ||
| 1 | <?php declare(strict_types = 1); |
||
| 20 | 16 | public function configureWithConfig(array $config): void |
|
| 21 | { |
||
| 22 | 16 | if (empty($config[AbstractAsynchronousMessageProducerFactory::KEY_BRIDGE])) { |
|
| 23 | 16 | return; |
|
| 24 | } |
||
| 25 | |||
| 26 | 5 | $interopContainerServiceId = $this->getInteropContainerServiceId(); |
|
| 27 | |||
| 28 | 5 | $asynchronousProducerDefinition = new Definition(AsynchronousMessageProducer::class); |
|
| 29 | $asynchronousProducerDefinition |
||
| 30 | 5 | ->setFactory($this->getProducerFactoryClass() . '::' . $this->getConfigKey()) |
|
| 31 | 5 | ->addArgument( |
|
| 32 | 5 | new Reference($interopContainerServiceId) |
|
| 33 | ); |
||
| 34 | |||
| 35 | 5 | $asynchronousProducerName = 'prooph.asynchronous_messaging.' . $this->getConfigKey(); |
|
| 36 | |||
| 37 | 5 | $this->containerBuilder->setDefinition($asynchronousProducerName, $asynchronousProducerDefinition); |
|
| 38 | 5 | } |
|
| 39 | } |
||
| 40 |