@@ 63-72 (lines=10) @@ | ||
60 | $definition->addMethodCall('setRedis', [new Reference('dtc_queue.'.$type)]); |
|
61 | } |
|
62 | ||
63 | protected function processPredisDsn(ContainerBuilder $container) |
|
64 | { |
|
65 | $definition = new Definition( |
|
66 | 'Predis\\Client', |
|
67 | [$container->getParameter('dtc_queue.redis.predis.dsn')] |
|
68 | ); |
|
69 | $container->setDefinition('dtc_queue.predis.client', $definition); |
|
70 | ||
71 | $this->setRedis($container, 'Predis', 'dtc_queue.predis.client', 'predis'); |
|
72 | } |
|
73 | ||
74 | protected function processPhpRedis(ContainerBuilder $container) |
|
75 | { |
|
@@ 95-104 (lines=10) @@ | ||
92 | $this->setRedis($container, 'PhpRedis', 'dtc_queue.phpredis.connection', 'phpredis'); |
|
93 | } |
|
94 | ||
95 | protected function processPredisConnectionParameters(ContainerBuilder $container) |
|
96 | { |
|
97 | $definition = new Definition( |
|
98 | 'Predis\\Client', |
|
99 | $container->getParameter('dtc_queue.redis.predis.connection_parameters') |
|
100 | ); |
|
101 | $container->setDefinition('dtc_queue.predis.client', $definition); |
|
102 | ||
103 | $this->setRedis($container, 'Predis', 'dtc_queue.predis.client', 'predis'); |
|
104 | } |
|
105 | } |
|
106 |