for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
/**
* DynamicConsumerCommand
*
* The context argument is passed to the consumer instance
* which can decide about the queue and routings it uses.
* @author Tibor Barna <[email protected]>
*/
namespace OldSound\RabbitMqBundle\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
class DynamicConsumerCommand extends BaseConsumerCommand
{
protected function configure(): void
parent::configure();
$this
->setName('rabbitmq:dynamic-consumer')
->setDescription('Executes context-aware consumer')
->addArgument('context', InputArgument::REQUIRED, 'Context the consumer runs in')
;
}
protected function getConsumerService()
return 'old_sound_rabbit_mq.%s_dynamic';
protected function initConsumer(InputInterface $input)
parent::initConsumer($input);
$this->consumer->setContext($input->getArgument('context'));
php-amqplib /
RabbitMqBundle
