From 3f1b73d1eb9663f5a223d417028ad68fb3bcd537 Mon Sep 17 00:00:00 2001
From: inklake <inklake@qq.com>
Date: Thu, 30 Aug 2018 14:38:48 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=20queue=20redis=20driver=20?=
 =?UTF-8?q?=E5=86=85=E7=9A=84=20=20=E5=8F=98=E9=87=8F=E9=94=99=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/taskphp/lib/queue/drives/Redis.php | 20 ++++++++++----------
 1 file changed, 10 insertions(+), 10 deletions(-)

diff --git a/src/taskphp/lib/queue/drives/Redis.php b/src/taskphp/lib/queue/drives/Redis.php
index fc62553..9155a31 100644
--- a/src/taskphp/lib/queue/drives/Redis.php
+++ b/src/taskphp/lib/queue/drives/Redis.php
@@ -17,7 +17,7 @@ namespace taskphp\queue\drives;
  * 1 环境中有redis，业务不需要ack
  */
 class Redis{
-    
+
     /**
      * 设置属性
      * @var array
@@ -28,7 +28,7 @@ class Redis{
         'port'=>'6379',
         'password'   => '',
     ];
-    
+
     /**
      * @var \Redis
      */
@@ -49,7 +49,7 @@ class Redis{
             $this->redis->auth($this->_options['password']);
         }
     }
-    
+
     /**
      * 读取缓存
      * @access public
@@ -61,7 +61,7 @@ class Redis{
         $value=unserialize($value);
         return $value;
     }
-    
+
     /**
      * 写入缓存
      * @access public
@@ -75,7 +75,7 @@ class Redis{
         $result = $this->redis->set($name, $value);
         return $result;
     }
-    
+
     /**
      * 删除缓存
      * @access public
@@ -83,9 +83,9 @@ class Redis{
      * @return boolen
      */
     public function rm($name) {
-        return $this->redis->delete($this->options['prefix'] . $name);
+        return $this->redis->delete($this->_options['prefix'] . $name);
     }
-    
+
     /**
      * 加入
      * @param string $key 表头
@@ -113,7 +113,7 @@ class Redis{
                 $wh=false;
                 break;
             }
-    
+
             if($timeout==0){
                 sleep(1);
             }elseif($timeout>0 && $second<$timeout){
@@ -125,7 +125,7 @@ class Redis{
         }
         return $res;
     }
-    
+
     /**
      * 删除 key 集合中的子集
      * @param unknown $key
@@ -145,7 +145,7 @@ class Redis{
         unset($data[$son_key]);
         return $this->set($key, $data);
     }
-    
+
     /**
      * 清除缓存
      * @access public
-- 
Gitee