Renamed queue to async-queue.

limingxinleo · limingxinleo · commit 57271f1e5027 · 2019-04-08T15:30:36.000+08:00
diff --git a/app/Commands/QueueCommand.php b/app/Commands/QueueCommand.php
@@ -12,8 +12,8 @@
 
 namespace App\Commands;
 
-use Hyperf\Queue\Driver\DriverFactory;
-use Hyperf\Queue\Driver\DriverInterface;
+use Hyperf\AsyncQueue\Driver\DriverFactory;
+use Hyperf\AsyncQueue\Driver\DriverInterface;
 use Psr\Container\ContainerInterface;
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputInterface;
diff --git a/app/Controllers/IndexController.php b/app/Controllers/IndexController.php
@@ -28,8 +28,8 @@
 use Hyperf\HttpServer\Annotation\GetMapping;
 use Hyperf\HttpServer\Contract\RequestInterface;
 use Hyperf\HttpServer\Contract\ResponseInterface;
-use Hyperf\Queue\Driver\DriverFactory;
-use Hyperf\Queue\Driver\DriverInterface;
+use Hyperf\AsyncQueue\Driver\DriverFactory;
+use Hyperf\AsyncQueue\Driver\DriverInterface;
 use Hyperf\Tracer\Tracing;
 use Psr\Container\ContainerInterface;
 use Swoole\Coroutine;
diff --git a/app/Jobs/AttemptsJob.php b/app/Jobs/AttemptsJob.php
@@ -12,7 +12,7 @@
 
 namespace App\Jobs;
 
-use Hyperf\Queue\Job;
+use Hyperf\AsyncQueue\Job;
 
 class AttemptsJob extends Job
 {
diff --git a/app/Jobs/EchoJob.php b/app/Jobs/EchoJob.php
@@ -12,7 +12,7 @@
 
 namespace App\Jobs;
 
-use Hyperf\Queue\Job;
+use Hyperf\AsyncQueue\Job;
 
 class EchoJob extends Job
 {
diff --git a/app/Listeners/QueueHandleListener.php b/app/Listeners/QueueHandleListener.php
@@ -16,11 +16,11 @@
 use Hyperf\Event\Contract\ListenerInterface;
 use Hyperf\Utils\ApplicationContext;
 use Hyperf\Contract\StdoutLoggerInterface;
-use Hyperf\Queue\Event\AfterHandle;
-use Hyperf\Queue\Event\BeforeHandle;
-use Hyperf\Queue\Event\Event;
-use Hyperf\Queue\Event\FailedHandle;
-use Hyperf\Queue\Event\RetryHandle;
+use Hyperf\AsyncQueue\Event\AfterHandle;
+use Hyperf\AsyncQueue\Event\BeforeHandle;
+use Hyperf\AsyncQueue\Event\Event;
+use Hyperf\AsyncQueue\Event\FailedHandle;
+use Hyperf\AsyncQueue\Event\RetryHandle;
 use Throwable;
 
 /**
diff --git a/composer.json b/composer.json
@@ -15,6 +15,7 @@
         "php": ">=7.2",
         "ext-swoole": ">=4.2",
         "hyperf/amqp": "dev-master",
+        "hyperf/async-queue": "dev-master",
         "hyperf/cache": "dev-master",
         "hyperf/circuit-breaker": "dev-master",
         "hyperf/config": "dev-master",
@@ -40,7 +41,6 @@
         "hyperf/paginator": "dev-master",
         "hyperf/pool": "dev-master",
         "hyperf/process": "dev-master",
-        "hyperf/queue": "dev-master",
         "hyperf/rate-limit": "dev-master",
         "hyperf/redis": "dev-master",
         "hyperf/tracer": "dev-master",
diff --git a/config/autoload/async_queue.php b/config/autoload/async_queue.php
@@ -2,7 +2,7 @@
 
 return [
     'default' => [
-        'driver' => \Hyperf\Queue\Driver\RedisDriver::class,
+        'driver' => \Hyperf\AsyncQueue\Driver\RedisDriver::class,
         'channel' => 'queue',
         'timeout' => 2,
         'retry_seconds' => 5,

Original file line number	Diff line number	Diff line change
`@@ -12,7 +12,7 @@`
`12`	`12`
`13`	`13`	`namespace App\Jobs;`
`14`	`14`
`15`		`-use Hyperf\Queue\Job;`
	`15`	`+use Hyperf\AsyncQueue\Job;`
`16`	`16`
`17`	`17`	`class AttemptsJob extends Job`
`18`	`18`	`{`