contamobi / CmobiRabbitmqBundle

        $container->setParameter('cmobi_rabbitmq.connection.factories', $factories);

    }

    public function loadRpcServers(ContainerBuilder $container, array $configs)

    {

        foreach ($configs['rpc_servers'] as $server) {

            $container->addCompilerPass(new RpcServerPass(

                $server['queue']['name'],

                $server['queue']['connection'],

                $server['service'],

                $server['queue']['basic_qos'],

                $server['queue']['durable'],

                $server['queue']['auto_delete'],

                $server['queue']['arguments']

            ));

        }

    }

    public function loadWorkers(ContainerBuilder $container, array $configs)

    {

        }

    }

    public function loadSubscribers(ContainerBuilder $container, array $configs)

    {

        foreach ($configs['subscribers'] as $subscriber) {

            $container->addCompilerPass(new SubscriberPass(

                $subscriber['queue']['exchange'],

                $subscriber['queue']['exchange_type'],

                $subscriber['queue']['name'],

                $subscriber['queue']['connection'],

                $subscriber['service'],

                $subscriber['queue']['basic_qos'],

                $subscriber['queue']['arguments']

            ));

        }

    }

}