Fixes #30 decrement received messages

Author: wushaobin

src/Consumer.php

@@ -225,7 +225,7 @@ public function receive(bool $loop = true): Message
             $this->messageQueue->enqueue($message);
         }
 
-        $consumer->decrement(1);
+        $consumer->decrement(sizeof($messages));
 
         return $this->messageQueue->dequeue();
     }
@@ -358,4 +358,4 @@ protected function getPartitionConsumer(int $consumerID): PartitionConsumer
         return $this->consumers[ $consumerID ];
     }
 
-}
+}

src/Reader.php

@@ -136,7 +136,7 @@ public function next(): Message
             $this->messageQueue->enqueue($message);
         }
 
-        $consumer->decrement(1);
+        $consumer->decrement(sizeof($messages));
 
         return $this->messageQueue->dequeue();
     }
@@ -176,4 +176,4 @@ protected function getWaitSeconds(): int
     {
         return 30;
     }
-}
+}