vendor/php-amqplib/rabbitmq-bundle/DependencyInjection/Configuration.php line 35

Open in your IDE?
  1. <?php
  3. namespace OldSound\RabbitMqBundle\DependencyInjection;
  5. use Symfony\Component\Config\Definition\Builder\TreeBuilder;
  6. use Symfony\Component\Config\Definition\ConfigurationInterface;
  7. use Symfony\Component\Config\Definition\Builder\ArrayNodeDefinition;
  9. /**
  10.  * Configuration
  11.  *
  12.  * @author Marc Weistroff <marc.weistroff@sensio.com>
  13.  */
  14. class Configuration implements ConfigurationInterface
  15. {
  16.     /**
  17.      * @var string
  18.      */
  19.     protected $name;
  21.     /**
  22.      * Configuration constructor.
  23.      *
  24.      * @param   string  $name
  25.      */
  26.     public function __construct($name)
  27.     {
  28.         $this->name = $name;
  29.     }
  31.     public function getConfigTreeBuilder()
  32.     {
  33.         $tree = new TreeBuilder();
  35.         $rootNode = $tree->root($this->name);
  37.         $rootNode
  38.             ->children()
  39.                 ->booleanNode('debug')->defaultValue('%kernel.debug%')->end()
  40.                 ->booleanNode('enable_collector')->defaultValue(false)->end()
  41.                 ->booleanNode('sandbox')->defaultValue(false)->end()
  42.             ->end()
  43.         ;
  45.         $this->addConnections($rootNode);
  46.         $this->addBindings($rootNode);
  47.         $this->addProducers($rootNode);
  48.         $this->addConsumers($rootNode);
  49.         $this->addMultipleConsumers($rootNode);
  50.         $this->addDynamicConsumers($rootNode);
  51.         $this->addBatchConsumers($rootNode);
  52.         $this->addAnonConsumers($rootNode);
  53.         $this->addRpcClients($rootNode);
  54.         $this->addRpcServers($rootNode);
  56.         return $tree;
  57.     }
  59.     protected function addConnections(ArrayNodeDefinition $node)
  60.     {
  61.         $node
  62.             ->fixXmlConfig('connection')
  63.             ->children()
  64.                 ->arrayNode('connections')
  65.                     ->useAttributeAsKey('key')
  66.                     ->canBeUnset()
  67.                     ->prototype('array')
  68.                         ->children()
  69.                             ->scalarNode('url')->defaultValue('')->end()
  70.                             ->scalarNode('host')->defaultValue('localhost')->end()
  71.                             ->scalarNode('port')->defaultValue(5672)->end()
  72.                             ->scalarNode('user')->defaultValue('guest')->end()
  73.                             ->scalarNode('password')->defaultValue('guest')->end()
  74.                             ->scalarNode('vhost')->defaultValue('/')->end()
  75.                             ->booleanNode('lazy')->defaultFalse()->end()
  76.                             ->scalarNode('connection_timeout')->defaultValue(3)->end()
  77.                             ->scalarNode('read_write_timeout')->defaultValue(3)->end()
  78.                             ->booleanNode('use_socket')->defaultValue(false)->end()
  79.                             ->arrayNode('ssl_context')
  80.                                 ->useAttributeAsKey('key')
  81.                                 ->canBeUnset()
  82.                                 ->prototype('variable')->end()
  83.                             ->end()
  84.                             ->booleanNode('keepalive')->defaultFalse()->info('requires php-amqplib v2.4.1+ and PHP5.4+')->end()
  85.                             ->scalarNode('heartbeat')->defaultValue(0)->info('requires php-amqplib v2.4.1+')->end()
  86.                             ->scalarNode('connection_parameters_provider')->end()
  87.                         ->end()
  88.                     ->end()
  89.                 ->end()
  90.             ->end()
  91.         ;
  92.     }
  94.     protected function addProducers(ArrayNodeDefinition $node)
  95.     {
  96.         $node
  97.             ->fixXmlConfig('producer')
  98.             ->children()
  99.                 ->arrayNode('producers')
  100.                     ->canBeUnset()
  101.                     ->useAttributeAsKey('key')
  102.                     ->prototype('array')
  103.                         ->append($this->getExchangeConfiguration())
  104.                         ->append($this->getQueueConfiguration())
  105.                         ->children()
  106.                             ->scalarNode('connection')->defaultValue('default')->end()
  107.                             ->scalarNode('auto_setup_fabric')->defaultTrue()->end()
  108.                             ->scalarNode('class')->defaultValue('%old_sound_rabbit_mq.producer.class%')->end()
  109.                             ->scalarNode('enable_logger')->defaultFalse()->end()
  110.                             ->scalarNode('service_alias')->defaultValue(null)->end()
  111.                         ->end()
  112.                     ->end()
  113.                 ->end()
  114.             ->end()
  115.         ;
  116.     }
  118.     protected function addBindings(ArrayNodeDefinition $node)
  119.     {
  120.         $node
  121.             ->fixXmlConfig('binding')
  122.             ->children()
  123.                 ->arrayNode('bindings')
  124.                     ->canBeUnset()
  125.                     ->prototype('array')
  126.                         ->children()
  127.                             ->scalarNode('connection')->defaultValue('default')->end()
  128.                             ->scalarNode('exchange')->defaultNull()->end()
  129.                             ->scalarNode('destination')->defaultNull()->end()
  130.                             ->scalarNode('routing_key')->defaultNull()->end()
  131.                             ->booleanNode('nowait')->defaultFalse()->end()
  132.                             ->booleanNode('destination_is_exchange')->defaultFalse()->end()
  133.                             ->variableNode('arguments')->defaultNull()->end()
  134.                             ->scalarNode('class')->defaultValue('%old_sound_rabbit_mq.binding.class%')->end()
  135.                         ->end()
  136.                     ->end()
  137.                 ->end()
  138.             ->end()
  139.         ;
  140.     }
  142.     protected function addConsumers(ArrayNodeDefinition $node)
  143.     {
  144.         $node
  145.             ->fixXmlConfig('consumer')
  146.             ->children()
  147.                 ->arrayNode('consumers')
  148.                     ->canBeUnset()
  149.                     ->useAttributeAsKey('key')
  150.                     ->prototype('array')
  151.                         ->append($this->getExchangeConfiguration())
  152.                         ->append($this->getQueueConfiguration())
  153.                         ->children()
  154.                             ->scalarNode('connection')->defaultValue('default')->end()
  155.                             ->scalarNode('callback')->isRequired()->end()
  156.                             ->scalarNode('idle_timeout')->end()
  157.                             ->scalarNode('idle_timeout_exit_code')->end()
  158.                             ->arrayNode('graceful_max_execution')
  159.                                 ->canBeUnset()
  160.                                 ->children()
  161.                                     ->integerNode('timeout')->end()
  162.                                     ->integerNode('exit_code')->defaultValue(0)->end()
  163.                                 ->end()
  164.                             ->end()
  165.                             ->scalarNode('auto_setup_fabric')->defaultTrue()->end()
  166.                             ->arrayNode('qos_options')
  167.                                 ->canBeUnset()
  168.                                 ->children()
  169.                                     ->scalarNode('prefetch_size')->defaultValue(0)->end()
  170.                                     ->scalarNode('prefetch_count')->defaultValue(0)->end()
  171.                                     ->booleanNode('global')->defaultFalse()->end()
  172.                                 ->end()
  173.                             ->end()
  174.                             ->scalarNode('enable_logger')->defaultFalse()->end()
  175.                         ->end()
  176.                     ->end()
  177.                 ->end()
  178.             ->end()
  179.         ;
  180.     }
  182.     protected function addMultipleConsumers(ArrayNodeDefinition $node)
  183.     {
  184.         $node
  185.             ->fixXmlConfig('multiple_consumer')
  186.             ->children()
  187.                 ->arrayNode('multiple_consumers')
  188.                 ->canBeUnset()
  189.                 ->useAttributeAsKey('key')
  190.                 ->prototype('array')
  191.                     ->append($this->getExchangeConfiguration())
  192.                     ->children()
  193.                         ->scalarNode('connection')->defaultValue('default')->end()
  194.                         ->scalarNode('idle_timeout')->end()
  195.                         ->scalarNode('idle_timeout_exit_code')->end()
  196.                         ->scalarNode('auto_setup_fabric')->defaultTrue()->end()
  197.                         ->arrayNode('graceful_max_execution')
  198.                             ->canBeUnset()
  199.                             ->children()
  200.                                 ->integerNode('timeout')->end()
  201.                                 ->integerNode('exit_code')->defaultValue(0)->end()
  202.                             ->end()
  203.                         ->end()
  204.                         ->append($this->getMultipleQueuesConfiguration())
  205.                         ->arrayNode('qos_options')
  206.                             ->canBeUnset()
  207.                             ->children()
  208.                                 ->scalarNode('prefetch_size')->defaultValue(0)->end()
  209.                                 ->scalarNode('prefetch_count')->defaultValue(0)->end()
  210.                                 ->booleanNode('global')->defaultFalse()->end()
  211.                             ->end()
  212.                         ->end()
  213.                         ->scalarNode('queues_provider')->defaultNull()->end()
  214.                         ->scalarNode('enable_logger')->defaultFalse()->end()
  215.                     ->end()
  216.                 ->end()
  217.             ->end()
  218.         ;
  219.     }
  220.     
  221.     protected function addDynamicConsumers(ArrayNodeDefinition $node)
  222.     {
  223.         $node
  224.             ->fixXmlConfig('dynamic_consumer')
  225.             ->children()
  226.                 ->arrayNode('dynamic_consumers')
  227.                     ->canBeUnset()
  228.                     ->useAttributeAsKey('key')
  229.                     ->prototype('array')
  230.                         ->append($this->getExchangeConfiguration())
  231.                         ->children()
  232.                             ->scalarNode('connection')->defaultValue('default')->end()
  233.                             ->scalarNode('callback')->isRequired()->end()
  234.                             ->scalarNode('idle_timeout')->end()
  235.                             ->scalarNode('idle_timeout_exit_code')->end()
  236.                             ->scalarNode('auto_setup_fabric')->defaultTrue()->end()
  237.                             ->arrayNode('qos_options')
  238.                                 ->canBeUnset()
  239.                                 ->children()
  240.                                     ->scalarNode('prefetch_size')->defaultValue(0)->end()
  241.                                     ->scalarNode('prefetch_count')->defaultValue(0)->end()
  242.                                     ->booleanNode('global')->defaultFalse()->end()
  243.                                 ->end()
  244.                             ->end()
  245.                             ->scalarNode('queue_options_provider')->isRequired()->end()
  246.                             ->scalarNode('enable_logger')->defaultFalse()->end()
  247.                         ->end()
  248.                     ->end()
  249.                 ->end()
  250.             ->end()
  251.         ;
  252.     }
  254.     /**
  255.      * @param   ArrayNodeDefinition     $node
  256.      *
  257.      * @return  void
  258.      */
  259.     protected function addBatchConsumers(ArrayNodeDefinition $node)
  260.     {
  261.         $node
  262.             ->children()
  263.                 ->arrayNode('batch_consumers')
  264.                     ->canBeUnset()
  265.                     ->useAttributeAsKey('key')
  266.                     ->prototype('array')
  267.                         ->append($this->getExchangeConfiguration())
  268.                         ->append($this->getQueueConfiguration())
  269.                         ->children()
  270.                             ->scalarNode('connection')->defaultValue('default')->end()
  271.                             ->scalarNode('callback')->isRequired()->end()
  272.                             ->scalarNode('idle_timeout')->end()
  273.                             ->scalarNode('timeout_wait')->defaultValue(3)->end()
  274.                             ->scalarNode('idle_timeout_exit_code')->end()
  275.                             ->scalarNode('keep_alive')->defaultFalse()->end()
  276.                             ->arrayNode('graceful_max_execution')
  277.                                 ->canBeUnset()
  278.                                 ->children()
  279.                                     ->integerNode('timeout')->end()
  280.                                 ->end()
  281.                             ->end()
  282.                             ->scalarNode('auto_setup_fabric')->defaultTrue()->end()
  283.                             ->arrayNode('qos_options')
  284.                                 ->children()
  285.                                     ->scalarNode('prefetch_size')->defaultValue(0)->end()
  286.                                     ->scalarNode('prefetch_count')->defaultValue(2)->end()
  287.                                     ->booleanNode('global')->defaultFalse()->end()
  288.                                 ->end()
  289.                             ->end()
  290.                             ->scalarNode('enable_logger')->defaultFalse()->end()
  291.                         ->end()
  292.                     ->end()
  293.                 ->end()
  294.             ->end()
  295.         ;
  296.     }
  298.     protected function addAnonConsumers(ArrayNodeDefinition $node)
  299.     {
  300.         $node
  301.             ->fixXmlConfig('anon_consumer')
  302.             ->children()
  303.                 ->arrayNode('anon_consumers')
  304.                     ->canBeUnset()
  305.                     ->useAttributeAsKey('key')
  306.                     ->prototype('array')
  307.                         ->append($this->getExchangeConfiguration())
  308.                         ->children()
  309.                             ->scalarNode('connection')->defaultValue('default')->end()
  310.                             ->scalarNode('callback')->isRequired()->end()
  311.                         ->end()
  312.                     ->end()
  313.                 ->end()
  314.             ->end()
  315.         ;
  316.     }
  318.     protected function addRpcClients(ArrayNodeDefinition $node)
  319.     {
  320.         $node
  321.             ->fixXmlConfig('rpc_client')
  322.             ->children()
  323.                 ->arrayNode('rpc_clients')
  324.                     ->canBeUnset()
  325.                     ->useAttributeAsKey('key')
  326.                     ->prototype('array')
  327.                         ->children()
  328.                             ->scalarNode('connection')->defaultValue('default')->end()
  329.                             ->booleanNode('expect_serialized_response')->defaultTrue()->end()
  330.                             ->scalarNode('unserializer')->defaultValue('unserialize')->end()
  331.                             ->booleanNode('lazy')->defaultFalse()->end()
  332.                             ->booleanNode('direct_reply_to')->defaultFalse()->end()
  333.                         ->end()
  334.                     ->end()
  335.                 ->end()
  336.             ->end()
  337.         ;
  338.     }
  340.     protected function addRpcServers(ArrayNodeDefinition $node)
  341.     {
  342.         $node
  343.             ->fixXmlConfig('rpc_server')
  344.             ->children()
  345.                 ->arrayNode('rpc_servers')
  346.                     ->canBeUnset()
  347.                     ->useAttributeAsKey('key')
  348.                     ->prototype('array')
  349.                         ->append($this->getExchangeConfiguration())
  350.                         ->append($this->getQueueConfiguration())
  351.                         ->children()
  352.                             ->scalarNode('connection')->defaultValue('default')->end()
  353.                             ->scalarNode('callback')->isRequired()->end()
  354.                             ->arrayNode('qos_options')
  355.                                 ->canBeUnset()
  356.                                 ->children()
  357.                                     ->scalarNode('prefetch_size')->defaultValue(0)->end()
  358.                                     ->scalarNode('prefetch_count')->defaultValue(0)->end()
  359.                                     ->booleanNode('global')->defaultFalse()->end()
  360.                                 ->end()
  361.                             ->end()
  362.                             ->scalarNode('serializer')->defaultValue('serialize')->end()
  363.                             ->scalarNode('enable_logger')->defaultFalse()->end()
  364.                         ->end()
  365.                     ->end()
  366.                 ->end()
  367.             ->end()
  368.         ;
  369.     }
  371.     protected function getExchangeConfiguration()
  372.     {
  373.         $node = new ArrayNodeDefinition('exchange_options');
  375.         return $node
  376.             ->children()
  377.                 ->scalarNode('name')->isRequired()->end()
  378.                 ->scalarNode('type')->isRequired()->end()
  379.                 ->booleanNode('passive')->defaultValue(false)->end()
  380.                 ->booleanNode('durable')->defaultValue(true)->end()
  381.                 ->booleanNode('auto_delete')->defaultValue(false)->end()
  382.                 ->booleanNode('internal')->defaultValue(false)->end()
  383.                 ->booleanNode('nowait')->defaultValue(false)->end()
  384.                 ->booleanNode('declare')->defaultValue(true)->end()
  385.                 ->variableNode('arguments')->defaultNull()->end()
  386.                 ->scalarNode('ticket')->defaultNull()->end()
  387.             ->end()
  388.         ;
  389.     }
  391.     protected function getQueueConfiguration()
  392.     {
  393.         $node = new ArrayNodeDefinition('queue_options');
  395.         $this->addQueueNodeConfiguration($node);
  397.         return $node;
  398.     }
  400.     protected function getMultipleQueuesConfiguration()
  401.     {
  402.         $node = new ArrayNodeDefinition('queues');
  403.         $prototypeNode = $node->prototype('array');
  405.         $this->addQueueNodeConfiguration($prototypeNode);
  407.         $prototypeNode->children()
  408.             ->scalarNode('callback')->isRequired()->end()
  409.         ->end();
  411.         $prototypeNode->end();
  413.         return $node;
  414.     }
  416.     protected function addQueueNodeConfiguration(ArrayNodeDefinition $node)
  417.     {
  418.         $node
  419.             ->fixXmlConfig('routing_key')
  420.             ->children()
  421.                 ->scalarNode('name')->end()
  422.                 ->booleanNode('passive')->defaultFalse()->end()
  423.                 ->booleanNode('durable')->defaultTrue()->end()
  424.                 ->booleanNode('exclusive')->defaultFalse()->end()
  425.                 ->booleanNode('auto_delete')->defaultFalse()->end()
  426.                 ->booleanNode('nowait')->defaultFalse()->end()
  427.                 ->booleanNode('declare')->defaultTrue()->end()
  428.                 ->variableNode('arguments')->defaultNull()->end()
  429.                 ->scalarNode('ticket')->defaultNull()->end()
  430.                 ->arrayNode('routing_keys')
  431.                     ->prototype('scalar')->end()
  432.                     ->defaultValue(array())
  433.                 ->end()
  434.             ->end()
  435.         ;
  436.     }
  437. }