diff --git a/README.md b/README.md index 4e4a681..233d535 100644 --- a/README.md +++ b/README.md @@ -21,6 +21,7 @@ REDIS_PASSWORD=null REDIS_PORT=6379 REDIS_SCHEME=tcp REDIS_DB=0 +REDIS_PREFIX=your_prefix ``` Update composer.json diff --git a/examples/.env b/examples/.env index d98e3ad..82b57f6 100644 --- a/examples/.env +++ b/examples/.env @@ -3,4 +3,5 @@ REDIS_CLIENT=predis REDIS_PASSWORD=null REDIS_PORT=6379 REDIS_SCHEME=tcp -REDIS_DB=0 \ No newline at end of file +REDIS_DB=0 +REDIS_PREFIX=myproject \ No newline at end of file diff --git a/examples/application/controllers/Queue.php b/examples/application/controllers/Queue.php index 94ca410..3becf5f 100644 --- a/examples/application/controllers/Queue.php +++ b/examples/application/controllers/Queue.php @@ -13,7 +13,7 @@ public function work() { $options = new Illuminate\Queue\WorkerOptions(); $options->maxTries = 5; $options->timeOut = 300; - $worker->daemon('redis', 'default', $options); + $worker->daemon('redis', $_ENV['REDIS_PREFIX'], $options); } } \ No newline at end of file diff --git a/src/Libraries/Queue.php b/src/Libraries/Queue.php index 9594b20..8a0800e 100644 --- a/src/Libraries/Queue.php +++ b/src/Libraries/Queue.php @@ -2,14 +2,14 @@ namespace Masrodjie\Queue\Libraries; -use Illuminate\Queue\Worker; +use Illuminate\Container\Container; +use Illuminate\Contracts\Debug\ExceptionHandler; +use Illuminate\Database\Capsule\Manager; use Illuminate\Events\Dispatcher; use Illuminate\Queue\Capsule\Manager as QueueManager; -use Illuminate\Contracts\Debug\ExceptionHandler; -use Illuminate\Container\Container; +use Illuminate\Queue\Worker; use Illuminate\Queue\WorkerOptions; use Illuminate\Redis\RedisManager; -use Illuminate\Database\Capsule\Manager; class Queue { @@ -23,7 +23,7 @@ public function __construct() 'queue.connections.redis' => [ 'driver' => 'redis', 'connection' => 'default', - 'queue' => 'default', + 'queue' => getenv('REDIS_PREFIX') != '' ? getenv('REDIS_PREFIX') : $_ENV['REDIS_PREFIX'], 'retry_after' => 30, ], 'queue.default' => 'redis',