Make sure dynamic consumer definition doesn’t mess with fabric setup (#463)

bouke-nederstigt · skafandri · commit a7d1a7c4af12 · 2017-09-20T21:51:15.000+03:00
diff --git a/Command/SetupFabricCommand.php b/Command/SetupFabricCommand.php
@@ -2,6 +2,7 @@
 
 namespace OldSound\RabbitMqBundle\Command;
 
+use OldSound\RabbitMqBundle\RabbitMq\DynamicConsumer;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Input\InputOption;
 use Symfony\Component\Console\Output\OutputInterface;
@@ -29,6 +30,9 @@ protected function execute(InputInterface $input, OutputInterface $output)
 
         foreach (array('base_amqp', 'binding') as $key) {
             foreach ($partsHolder->getParts('old_sound_rabbit_mq.' . $key) as $baseAmqp) {
+                if ($baseAmqp instanceof DynamicConsumer) {
+                    continue;
+                }
                 $baseAmqp->setupFabric();
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -2,6 +2,7 @@`
`2`	`2`
`3`	`3`	`namespace OldSound\RabbitMqBundle\Command;`
`4`	`4`
	`5`	`+use OldSound\RabbitMqBundle\RabbitMq\DynamicConsumer;`
`5`	`6`	`use Symfony\Component\Console\Input\InputInterface;`
`6`	`7`	`use Symfony\Component\Console\Input\InputOption;`
`7`	`8`	`use Symfony\Component\Console\Output\OutputInterface;`
`@@ -29,6 +30,9 @@ protected function execute(InputInterface $input, OutputInterface $output)`
`29`	`30`
`30`	`31`	`foreach (array('base_amqp', 'binding') as $key) {`
`31`	`32`	`foreach ($partsHolder->getParts('old_sound_rabbit_mq.' . $key) as $baseAmqp) {`
	`33`	`+ if ($baseAmqp instanceof DynamicConsumer) {`
	`34`	`+ continue;`
	`35`	`+ }`
`32`	`36`	`$baseAmqp->setupFabric();`
`33`	`37`	`}`
`34`	`38`	`}`