etna-alternance / composer-rabbitmq-service-provider

                $consumer->setQueueOptions($options['queue_options']);

                $consumer->setCallback(array($app[$options['callback']], 'execute'));

                if (array_key_exists('qos_options', $options)) {

                    $consumer->setQosOptions(

                        $options['qos_options']['prefetch_size'],

                        $options['qos_options']['prefetch_count'],

                        $options['qos_options']['global']

                    );

                }

                if (array_key_exists('qos_options', $options)) {

                    $consumer->setIdleTimeout($options['idle_timeout']);

                $consumer->setExchangeOptions($options['exchange_options']);

                $consumer->setQueues($options['queues']);

                if (array_key_exists('qos_options', $options)) {

                    $consumer->setQosOptions(

                        $options['qos_options']['prefetch_size'],

                        $options['qos_options']['prefetch_count'],

                        $options['qos_options']['global']

                    );

                }

                if (array_key_exists('qos_options', $options)) {

                    $consumer->setIdleTimeout($options['idle_timeout']);

                $server->initServer($name);

                $server->setCallback(array($options['callback'], 'execute'));

                if (array_key_exists('qos_options', $options)) {

                    $server->setQosOptions(

                        $options['qos_options']['prefetch_size'],

                        $options['qos_options']['prefetch_count'],

                        $options['qos_options']['global']

                    );

                }

                $servers[$name] = $server;

            }