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