From 9569834201ec6d6f443be3b300e3fd6af25cbd90 Mon Sep 17 00:00:00 2001 From: Bardo Date: Mon, 7 Dec 2020 13:57:32 +0800 Subject: [PATCH 1/2] modifu RedisQueue.php --- README.md | 1 + composer.json | 6 +++++- src/RedisQueue.php | 4 ++-- 3 files changed, 8 insertions(+), 3 deletions(-) diff --git a/README.md b/README.md index cb50e66..a9184aa 100644 --- a/README.md +++ b/README.md @@ -6,6 +6,7 @@ Phive Queue Phive Queue is a time-based scheduling queue with multiple backend support. +This package is forked from https://github.com/rybakit/phive-queue ## Table of contents diff --git a/composer.json b/composer.json index f9d4d6a..0ae3917 100644 --- a/composer.json +++ b/composer.json @@ -1,5 +1,5 @@ { - "name": "rybakit/phive-queue", + "name": "bardoqi/phive-queue", "description": "$queue->push('I can be popped off after', '10 minutes');", "keywords": ["queue", "schedule", "priority", "delayed", "mongodb", "redis", "tarantool", "beanstalk", "sysv", "postgres", "mysql", "sqlite", "pdo"], "homepage": "https://github.com/rybakit/phive-queue", @@ -9,6 +9,10 @@ { "name": "Eugene Leonovich", "email": "gen.work@gmail.com" + }, + { + "name": "Bardo Qi", + "email": "bardoqi@gmail.com" } ], "require": { diff --git a/src/RedisQueue.php b/src/RedisQueue.php index af0a55a..8dea58f 100644 --- a/src/RedisQueue.php +++ b/src/RedisQueue.php @@ -49,7 +49,7 @@ public function push($item, $eta = null) $item = $this->redis->_serialize($item); } - $result = $this->redis->evaluate(self::SCRIPT_PUSH, ['items', 'seq', $item, $eta], 2); + $result = $this->redis->eval(self::SCRIPT_PUSH, ['items', 'seq', $item, $eta], 2); $this->assertResult($result); } @@ -58,7 +58,7 @@ public function push($item, $eta = null) */ public function pop() { - $result = $this->redis->evaluate(self::SCRIPT_POP, ['items', time()], 1); + $result = $this->redis->eval(self::SCRIPT_POP, ['items', time()], 1); $this->assertResult($result); if (-1 === $result) { From 1542f4d5a8bad5f721251885fd57b594ce9882e5 Mon Sep 17 00:00:00 2001 From: Bardo Date: Mon, 7 Dec 2020 14:04:34 +0800 Subject: [PATCH 2/2] revert --- README.md | 1 - composer.json | 6 +----- 2 files changed, 1 insertion(+), 6 deletions(-) diff --git a/README.md b/README.md index a9184aa..cb50e66 100644 --- a/README.md +++ b/README.md @@ -6,7 +6,6 @@ Phive Queue Phive Queue is a time-based scheduling queue with multiple backend support. -This package is forked from https://github.com/rybakit/phive-queue ## Table of contents diff --git a/composer.json b/composer.json index 0ae3917..f9d4d6a 100644 --- a/composer.json +++ b/composer.json @@ -1,5 +1,5 @@ { - "name": "bardoqi/phive-queue", + "name": "rybakit/phive-queue", "description": "$queue->push('I can be popped off after', '10 minutes');", "keywords": ["queue", "schedule", "priority", "delayed", "mongodb", "redis", "tarantool", "beanstalk", "sysv", "postgres", "mysql", "sqlite", "pdo"], "homepage": "https://github.com/rybakit/phive-queue", @@ -9,10 +9,6 @@ { "name": "Eugene Leonovich", "email": "gen.work@gmail.com" - }, - { - "name": "Bardo Qi", - "email": "bardoqi@gmail.com" } ], "require": {