Skip to content

Commit 4bd0ec1

Browse files
vasilevrvskafandri
vasilevrv
authored andcommitted
Public comsumers (batch/dynamic/anon) for Symfony > 3.2.x (#539)
1 parent 6fe3060 commit 4bd0ec1

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

DependencyInjection/OldSoundRabbitMqExtension.php

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -262,8 +262,8 @@ protected function loadMultipleConsumers()
262262
}
263263

264264
$definition = new Definition('%old_sound_rabbit_mq.multi_consumer.class%');
265-
$definition->setPublic(true);
266265
$definition
266+
->setPublic(true)
267267
->addTag('old_sound_rabbit_mq.base_amqp')
268268
->addTag('old_sound_rabbit_mq.multi_consumer')
269269
->addMethodCall('setExchangeOptions', array($this->normalizeArgumentKeys($consumer['exchange_options'])))
@@ -337,6 +337,7 @@ protected function loadDynamicConsumers()
337337

338338
$definition = new Definition('%old_sound_rabbit_mq.dynamic_consumer.class%');
339339
$definition
340+
->setPublic(true)
340341
->addTag('old_sound_rabbit_mq.base_amqp')
341342
->addTag('old_sound_rabbit_mq.consumer')
342343
->addTag('old_sound_rabbit_mq.dynamic_consumer')
@@ -392,6 +393,7 @@ protected function loadBatchConsumers()
392393
}
393394

394395
$definition
396+
->setPublic(true)
395397
->addTag('old_sound_rabbit_mq.base_amqp')
396398
->addTag('old_sound_rabbit_mq.batch_consumer')
397399
->addMethodCall('setTimeoutWait', array($consumer['timeout_wait']))
@@ -440,6 +442,7 @@ protected function loadAnonConsumers()
440442
foreach ($this->config['anon_consumers'] as $key => $anon) {
441443
$definition = new Definition('%old_sound_rabbit_mq.anon_consumer.class%');
442444
$definition
445+
->setPublic(true)
443446
->addTag('old_sound_rabbit_mq.base_amqp')
444447
->addTag('old_sound_rabbit_mq.anon_consumer')
445448
->addMethodCall('setExchangeOptions', array($this->normalizeArgumentKeys($anon['exchange_options'])))

0 commit comments

Comments
 (0)