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 |
|
| @@ 108-114 (lines=7) @@ | ||
| 105 | * |
|
| 106 | * @return Task |
|
| 107 | */ |
|
| 108 | public function release($taskId, array $options = []) |
|
| 109 | { |
|
| 110 | $args = $options ? [$taskId, $options] : [$taskId]; |
|
| 111 | $result = $this->client->call("queue.tube.$this->name:release", $args); |
|
| 112 | ||
| 113 | return Task::createFromTuple($result[0]); |
|
| 114 | } |
|
| 115 | ||
| 116 | /** |
|
| 117 | * @param int $taskId |
|
