File tree Expand file tree Collapse file tree 1 file changed +20
-14
lines changed Expand file tree Collapse file tree 1 file changed +20
-14
lines changed Original file line number Diff line number Diff line change @@ -51,20 +51,26 @@ final class PingSiteJob extends JobHandler
51
51
52
52
接下来,我们需要配置我们的应用程序,以便将任务发送到 RoadRunner。 打开 ` app/config/queue.php ` 文件,并将以下配置添加到该文件中:
53
53
54
- ``` php app/src/Endpoint/Job/PingSiteJob.php
55
- namespace App\Endpoint\Job;
56
-
57
- use Spiral\Queue\JobHandler;
58
-
59
- final class PingSiteJob extends JobHandler
60
- {
61
- public function invoke(HttpClientInterface $client, string $site): void
62
- {
63
- $response = $client->request('GET', $site);
64
-
65
- // do something with response
66
- }
67
- }
54
+ ``` php app/config/queue.php
55
+ use Spiral\RoadRunner\Jobs\Queue\MemoryCreateInfo;
56
+
57
+ return [
58
+ 'default' => env('QUEUE_CONNECTION', 'roadrunner'),
59
+
60
+ pipelines' => [
61
+ 'memory' => [
62
+ 'connector' => new MemoryCreateInfo('local'),
63
+ 'consume' => true,
64
+ ]
65
+ ],
66
+
67
+ 'connections' => [
68
+ 'roadrunner' => [
69
+ 'driver' => 'roadrunner',
70
+ 'default' => 'memory',
71
+ ],
72
+ ],
73
+ ];
68
74
```
69
75
70
76
这些配置将创建一个新的 ` in-memory ` 队列来处理您的任务。
You can’t perform that action at this time.
0 commit comments