tarantool-php /
queue
| @@ 56-62 (lines=7) @@ | ||
| 53 | * |
|
| 54 | * @return Task |
|
| 55 | */ |
|
| 56 | public function put($data, array $options = []) |
|
| 57 | { |
|
| 58 | $args = $options ? [$data, $options] : [$data]; |
|
| 59 | $result = $this->client->call("queue.tube.$this->name:put", $args); |
|
| 60 | ||
| 61 | return Task::createFromTuple($result[0]); |
|
| 62 | } |
|
| 63 | ||
| 64 | /** |
|
| 65 | * @param int|float|null $timeout |
|
| @@ 95-101 (lines=7) @@ | ||
| 92 | * |
|
| 93 | * @return Task |
|
| 94 | */ |
|
| 95 | public function release($taskId, array $options = []) |
|
| 96 | { |
|
| 97 | $args = $options ? [$taskId, $options] : [$taskId]; |
|
| 98 | $result = $this->client->call("queue.tube.$this->name:release", $args); |
|
| 99 | ||
| 100 | return Task::createFromTuple($result[0]); |
|
| 101 | } |
|
| 102 | ||
| 103 | /** |
|
| 104 | * @param int $taskId |
|
