fix swoft-cloud/swoft-component#82

swoft-cloud · Sep 26, 2018 · 61469f2 · 61469f2
1 parent 6faa845
commit 61469f2
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/src/Profile/RedisProfile.php b/src/Profile/RedisProfile.php
@@ -20,6 +20,15 @@ abstract class RedisProfile implements ProfileInterface
      */
     protected $processor;
 
+    /**
+     * Setter prefix
+     * @param string $prefix
+     */
+    public function setPrefix(string $prefix)
+    {
+        $this->processor->setPrefix($prefix);
+    }
+
     /**
      * Init
      */

diff --git a/src/RedisConnection.php b/src/RedisConnection.php
@@ -69,6 +69,7 @@ public function __call($method, $arguments)
     {
         /* @var RedisCommandProvider $commandProvider */
         $commandProvider = App::getBean(RedisCommandProvider::class);
+        $commandProvider->setPrefix($this->pool->getPoolConfig()->getPrefix());
         $command         = $commandProvider->createCommand($method, $arguments);
         $arguments       = $command->getArguments();
         $method          = $command->getId();