Skip to content

Commit e2522d8

Browse files
committed
fix method definitions
1 parent 590e531 commit e2522d8

File tree

4 files changed

+8
-7
lines changed

4 files changed

+8
-7
lines changed

Command/BaseConsumerCommand.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ protected function configure()
4444
->addArgument('name', InputArgument::REQUIRED, 'Consumer Name')
4545
->addOption('messages', 'm', InputOption::VALUE_OPTIONAL, 'Messages to consume', '0')
4646
->addOption('route', 'r', InputOption::VALUE_OPTIONAL, 'Routing Key', '')
47-
->addOption('memory-limit', 'l', InputOption::VALUE_OPTIONAL, 'Allowed memory for this process (MB)', null)
47+
->addOption('memory-limit', 'l', InputOption::VALUE_OPTIONAL, 'Allowed memory for this process (MB)')
4848
->addOption('debug', 'd', InputOption::VALUE_NONE, 'Enable Debugging')
4949
->addOption('without-signals', 'w', InputOption::VALUE_NONE, 'Disable catching of system signals')
5050
;

Command/BatchConsumerCommand.php

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,11 +38,10 @@ protected function configure()
3838
->addArgument('name', InputArgument::REQUIRED, 'Consumer Name')
3939
->addOption('batches', 'b', InputOption::VALUE_OPTIONAL, 'Number of batches to consume', '0')
4040
->addOption('route', 'r', InputOption::VALUE_OPTIONAL, 'Routing Key', '')
41-
->addOption('memory-limit', 'l', InputOption::VALUE_OPTIONAL, 'Allowed memory for this process', null)
41+
->addOption('memory-limit', 'l', InputOption::VALUE_OPTIONAL, 'Allowed memory for this process')
4242
->addOption('debug', 'd', InputOption::VALUE_NONE, 'Enable Debugging')
4343
->addOption('without-signals', 'w', InputOption::VALUE_NONE, 'Disable catching of system signals')
4444
->setDescription('Executes a Batch Consumer');
45-
;
4645
}
4746

4847
/**

Command/DynamicConsumerCommand.php

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
/**
44
* DynamicConsumerCommand
5-
*
5+
*
66
* The context argument is passed to the consumer instance
77
* which can decide about the queue and routings it uses.
88
*
@@ -11,6 +11,7 @@
1111
namespace OldSound\RabbitMqBundle\Command;
1212

1313
use Symfony\Component\Console\Input\InputArgument;
14+
use Symfony\Component\Console\Input\InputInterface;
1415

1516
class DynamicConsumerCommand extends BaseConsumerCommand
1617
{
@@ -30,7 +31,7 @@ protected function getConsumerService()
3031
return 'old_sound_rabbit_mq.%s_dynamic';
3132
}
3233

33-
protected function initConsumer($input)
34+
protected function initConsumer(InputInterface $input)
3435
{
3536
parent::initConsumer($input);
3637
$this->consumer->setContext($input->getArgument('context'));

Command/MultipleConsumerCommand.php

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
namespace OldSound\RabbitMqBundle\Command;
44

55
use Symfony\Component\Console\Input\InputArgument;
6+
use Symfony\Component\Console\Input\InputInterface;
67

78
class MultipleConsumerCommand extends BaseConsumerCommand
89
{
@@ -21,9 +22,9 @@ protected function getConsumerService()
2122
return 'old_sound_rabbit_mq.%s_multiple';
2223
}
2324

24-
protected function initConsumer($input)
25+
protected function initConsumer(InputInterface $input)
2526
{
2627
parent::initConsumer($input);
2728
$this->consumer->setContext($input->getArgument('context'));
2829
}
29-
}
30+
}

0 commit comments

Comments
 (0)