Bug with "limfifottl" queues when capacity is reached

Fix bug tarantool-php#21 (comment)
PavelFil · Oct 20, 2022 · b3d2538 · b3d2538
1 parent a4e3934
commit b3d2538
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/src/Queue.php b/src/Queue.php
@@ -39,11 +39,10 @@ public function getName() : string
     /**
      * @param mixed $data
      */
-    public function put($data, array $options = []) : Task
+    public function put($data, array $options = []) : ?Task
     {
-        return Task::fromTuple(
-            $this->client->call("queue.tube.$this->name:put", $data, $options)[0]
-        );
+        $result = $this->client->call("queue.tube.$this->name:put", $data, $options);
+        return is_null($result[0]) ? null : Task::fromTuple($result[0]);
     }
 
     public function take(float $timeout = null) : ?Task