contamobi /
CmobiRabbitmqBundle
| @@ 58-72 (lines=15) @@ | ||
| 55 | $container->setParameter('cmobi_rabbitmq.connection.factories', $factories); |
|
| 56 | } |
|
| 57 | ||
| 58 | public function loadRpcServers(ContainerBuilder $container, array $configs) |
|
| 59 | { |
|
| 60 | foreach ($configs['rpc_servers'] as $server) { |
|
| 61 | ||
| 62 | $container->addCompilerPass(new RpcServerPass( |
|
| 63 | $server['queue']['name'], |
|
| 64 | $server['queue']['connection'], |
|
| 65 | $server['service'], |
|
| 66 | $server['queue']['basic_qos'], |
|
| 67 | $server['queue']['durable'], |
|
| 68 | $server['queue']['auto_delete'], |
|
| 69 | $server['queue']['arguments'] |
|
| 70 | )); |
|
| 71 | } |
|
| 72 | } |
|
| 73 | ||
| 74 | public function loadWorkers(ContainerBuilder $container, array $configs) |
|
| 75 | { |
|
| @@ 87-100 (lines=14) @@ | ||
| 84 | } |
|
| 85 | } |
|
| 86 | ||
| 87 | public function loadSubscribers(ContainerBuilder $container, array $configs) |
|
| 88 | { |
|
| 89 | foreach ($configs['subscribers'] as $subscriber) { |
|
| 90 | $container->addCompilerPass(new SubscriberPass( |
|
| 91 | $subscriber['queue']['exchange'], |
|
| 92 | $subscriber['queue']['exchange_type'], |
|
| 93 | $subscriber['queue']['name'], |
|
| 94 | $subscriber['queue']['connection'], |
|
| 95 | $subscriber['service'], |
|
| 96 | $subscriber['queue']['basic_qos'], |
|
| 97 | $subscriber['queue']['arguments'] |
|
| 98 | )); |
|
| 99 | } |
|
| 100 | } |
|
| 101 | ||
| 102 | /** |
|
| 103 | * @param ContainerBuilder $container |
|
