test/hyperf
1
0
Fork 0
mirror of https://gitee.com/hyperf/hyperf.git synced 2024-11-30 18:57:51 +08:00
Code Issues Actions 16 Packages Projects Releases Wiki Activity

Renamed queue to async-queue.

Browse Source
This commit is contained in:
李铭昕 2019-04-10 14:28:15 +08:00
parent 3a7a1e535c
commit 6af4bf3cb6
2 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
summary.md
View File

@ -56,7 +56,7 @@
* [Consul 协程客户端](zh/consul.md)
* [ETCD 协程客户端](zh/etcd.md)
* [AMQP](zh/amqp.md)
* [Redis 消息队列](zh/redis-queue.md)
* [异步队列](zh/async-queue.md)
* [内存操作](zh/memory.md)
* [自定义进程](zh/process.md)
* [开发者工具](zh/devtool.md)

22
zh/redis-queue.md → zh/async-queue.md
View File

@ -5,26 +5,26 @@
## 安装
```bash
composer require hyperf/queue
composer require hyperf/async-queue
```
## 配置
暂时只支持 `Redis Driver`。
| 配置 | 类型 | 默认值 | 备注 |
|:-------------:|:------:|:--------------------------------------:|:------------------:|
| driver | string | Hyperf\Queue\Driver\RedisDriver::class | 无 |
| channel | string | queue | 队列前缀 |
| retry_seconds | int | 5 | 失败后重新尝试间隔 |
| processes | int | 1 | 消费进程数 |
| 配置 | 类型 | 默认值 | 备注 |
|:-------------:|:------:|:-------------------------------------------:|:------------------:|
| driver | string | Hyperf\AsyncQueue\Driver\RedisDriver::class | 无 |
| channel | string | queue | 队列前缀 |
| retry_seconds | int | 5 | 失败后重新尝试间隔 |
| processes | int | 1 | 消费进程数 |
```php
<?php
return [
'default' => [
'driver' => Hyperf\Queue\Driver\RedisDriver::class,
'driver' => Hyperf\AsyncQueue\Driver\RedisDriver::class,
'channel' => 'queue',
'retry_seconds' => 5,
'processes' => 1,
@ -43,7 +43,7 @@ return [
<?php
return [
Hyperf\Queue\Process\ConsumerProcess::class,
Hyperf\AsyncQueue\Process\ConsumerProcess::class,
];
```
@ -59,7 +59,7 @@ declare(strict_types=1);
namespace App\Jobs;
use Hyperf\Queue\Job;
use Hyperf\AsyncQueue\Job;
class ExampleJob extends Job
{
@ -80,7 +80,7 @@ class ExampleJob extends Job
declare(strict_types=1);
use Psr\Container\ContainerInterface;
use Hyperf\Queue\Driver\DriverFactory;
use Hyperf\AsyncQueue\Driver\DriverFactory;
class DemoService
{