Enqueue\SimpleBus\Bridge\Symfony\Bundle\DependencyInjection\Configuration::messagesNode()

Complexity

Conditions	1
Paths	1

Size

Total Lines	31
Code Lines	28

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    private function messagesNode(string $type): ArrayNodeDefinition
    {
        return (new ArrayNodeDefinition($type))
            ->beforeNormalization()
                ->ifString()
                ->then(function (string $config): array {
                    return ['default_queue' => $config, 'enabled' => true];
                })
            ->end()
            ->canBeEnabled()

The method canBeEnabled() does not exist on Symfony\Component\Config\Definition\Builder\NodeDefinition. It seems like you code against a sub-type of Symfony\Component\Config\Definition\Builder\NodeDefinition such as Symfony\Component\Config\Definition\Builder\ArrayNodeDefinition.

            ->children()
                ->scalarNode('transport_name')
                    ->cannotBeEmpty()
                    ->defaultValue('default')
                ->end()
                ->scalarNode('default_queue')
                    ->cannotBeEmpty()
                    ->defaultValue(sprintf('asynchronous_%s', $type))
                ->end()
                ->scalarNode('processor_service_id')
                    ->cannotBeEmpty()
                    ->defaultValue(sprintf('enqueue.simple_bus.%s_processor', $type))
                ->end()
                ->arrayNode('queue_map')
                    ->requiresAtLeastOneElement()
                    ->useAttributeAsKey(true)
                    ->scalarPrototype()
                        ->isRequired()
                    ->end()
                ->end()
            ->end()
        ;