Fix message from batch consumer command (#42)

* Fixed message in BatchConsumerCommand and removed amount property

Author: andreea-anamaria

Command/BatchConsumerCommand.php

@@ -16,9 +16,6 @@ final class BatchConsumerCommand extends BaseRabbitMqCommand
      */
     protected $consumer;
 
-    /** @var int */
-    protected $amount;
-
     public function stopConsumer()
     {
         if ($this->consumer instanceof BatchConsumer) {
@@ -78,15 +75,15 @@ protected function execute(InputInterface $input, OutputInterface $output)
             define('AMQP_DEBUG', (bool) $input->getOption('debug'));
         }
 
-        $this->amount = (int) $input->getOption('batches');
+        $batchAmountTarget = (int) $input->getOption('batches');
 
-        if (0 > $this->amount) {
-            throw new \InvalidArgumentException("The -b option should be null or greater than 0");
+        if (0 > $batchAmountTarget) {
+            throw new \InvalidArgumentException("The -b option should be greater than 0");
         }
 
         $this->initConsumer($input);
 
-        return $this->consumer->consume($this->amount);
+        return $this->consumer->consume($batchAmountTarget);
     }
 
     /**

RabbitMq/BatchConsumer.php

@@ -76,7 +76,7 @@ class BatchConsumer extends BaseAmqp implements DequeuerInterface
     protected $gracefulMaxExecutionDateTime;
 
     /** @var int */
-    private $target;
+    private $batchAmountTarget;
 
     /**
      * @param \DateTime|null $dateTime
@@ -106,9 +106,9 @@ public function setCallback($callback)
         return $this;
     }
 
-    public function consume(int $batchAmount = 0)
+    public function consume(int $batchAmountTarget = 0)
     {
-        $this->target = $batchAmount;
+        $this->batchAmountTarget = $batchAmountTarget;
 
         $this->setupConsumer();
 
@@ -372,7 +372,7 @@ protected function maybeStopConsumer()
             pcntl_signal_dispatch();
         }
 
-        if ($this->forceStop || ($this->batchAmount == $this->target && $this->target > 0)) {
+        if ($this->forceStop || ($this->batchAmount == $this->batchAmountTarget && $this->batchAmountTarget > 0)) {
             $this->stopConsuming();
         }