From 17ecfe723f3e78e09e42bb0f33806cd9539f8e62 Mon Sep 17 00:00:00 2001 From: hsldymq Date: Mon, 15 Apr 2019 15:54:00 +0800 Subject: [PATCH] update examples --- examples/01.basic.php | 4 ++-- examples/04.prefetch.php | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/examples/01.basic.php b/examples/01.basic.php index 0d32143..2745cc0 100644 --- a/examples/01.basic.php +++ b/examples/01.basic.php @@ -25,8 +25,8 @@ ->setMessageHandler(function (QueueMessage $message, Worker $worker) { // 模拟正常处理逻辑 usleep(1000); - }) - ->registerSignal(SIGINT, function () { + }) + ->registerSignal(SIGINT, function () { // Ctrl+C会向前端进程组发送SIGINT信号,我们不希望worker也被这个信号影响,而是希望由dispatcher来控制它的生存周期 }) ->registerEvent('error', function (string $reason, \Throwable $e, Worker $worker) { diff --git a/examples/04.prefetch.php b/examples/04.prefetch.php index a82d88d..48b5bbe 100644 --- a/examples/04.prefetch.php +++ b/examples/04.prefetch.php @@ -33,7 +33,7 @@ $params = require __DIR__.'/amqp_params.php'; $conn = new Connection($params['connectionOptions'], $params['queues']); -// !!!!!!!!!!就是这里!!!!!!!!!!!! +// 使用该方法设置prefetch值 $conn->setPrefetch(10); $dispatcher = (new Dispatcher($conn, $factory))