From 137ef76177acce4479f2852a426d4a81dde642c1 Mon Sep 17 00:00:00 2001 From: starinacool Date: Mon, 20 Apr 2020 12:27:37 +0700 Subject: [PATCH 1/2] Setting Redis::OPT_READ_TIMEOUT Redis throws an Exception if Redis::OPT_READ_TIMEOUT is less then BRPOPLPUSH timeout --- README.md | 3 +++ 1 file changed, 3 insertions(+) diff --git a/README.md b/README.md index 216da51..0b6056b 100644 --- a/README.md +++ b/README.md @@ -19,6 +19,9 @@ use Altmetric\ReliableQueue; use Altmetric\ChunkedReliableQueue; use Altmetric\PriorityReliableQueue; +//Read timeout should be higher then BRPOPLPUSH timeout or -1 for infinity +$redis->setOption(Redis::OPT_READ_TIMEOUT, -1); + $queue = new ReliableQueue('unique-worker-name', 'to-do-queue', $redis, $logger); $queue[] = 'some-work'; $queue[] = 'some-more-work'; From 7b027acb39cbeccfe7c82e7c0106b55c04c30851 Mon Sep 17 00:00:00 2001 From: starinacool Date: Mon, 20 Apr 2020 12:31:57 +0700 Subject: [PATCH 2/2] Only for PHP 5.6 --- README.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index 0b6056b..ac527a4 100644 --- a/README.md +++ b/README.md @@ -19,8 +19,8 @@ use Altmetric\ReliableQueue; use Altmetric\ChunkedReliableQueue; use Altmetric\PriorityReliableQueue; -//Read timeout should be higher then BRPOPLPUSH timeout or -1 for infinity -$redis->setOption(Redis::OPT_READ_TIMEOUT, -1); +//Read timeout should be higher then BRPOPLPUSH timeout or -1 for infinity (PHP >=5.6) +//$redis->setOption(Redis::OPT_READ_TIMEOUT, -1); $queue = new ReliableQueue('unique-worker-name', 'to-do-queue', $redis, $logger); $queue[] = 'some-work';