Merge pull request #20 from SpinninRecordsOfficial/master

Return an empty array when the payload is empty
mmoreram · May 18, 2016 · 0038d4a · 0038d4a
2 parents 533ae1b + b01155d
commit 0038d4a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/Services/Consumer.php b/Services/Consumer.php
@@ -43,6 +43,10 @@ public function consume($queueAlias, $timeout = 0)
 
         $payloadArray = $this->redis->blpop($queues, $timeout);
 
+        if (empty($payloadArray)) {
+            return array();
+        }
+
         list($givenQueue, $payloadSerialized) = $payloadArray;
         $payload = $this->serializer->revert($payloadSerialized);
         $givenQueueAlias = $this->queueAliasResolver->getQueueAlias($givenQueue);