|
@@ -78,7 +78,7 @@ discard block |
|
|
block discarded – undo |
|
78
|
78
|
define('AMQP_DEBUG', (bool) $input->getOption('debug')); |
|
79
|
79
|
} |
|
80
|
80
|
|
|
81
|
|
- $this->amount = (int)$input->getOption('messages'); |
|
|
81
|
+ $this->amount = (int) $input->getOption('messages'); |
|
82
|
82
|
|
|
83
|
83
|
if (0 > (int) $this->amount) { |
|
84
|
84
|
throw new \InvalidArgumentException("The -m option should be null or greater than 0"); |
|
@@ -86,7 +86,7 @@ discard block |
|
|
block discarded – undo |
|
86
|
86
|
|
|
87
|
87
|
$this->initConsumer($input); |
|
88
|
88
|
|
|
89
|
|
- return $this->consumer->consume((int)$this->amount); |
|
|
89
|
+ return $this->consumer->consume((int) $this->amount); |
|
90
|
90
|
} |
|
91
|
91
|
|
|
92
|
92
|
/** |
Please login to merge, or discard this patch.