From 3ed3abeda2cb37d905c77990576ba2ab84f087bc Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Mr=C2=B7x?= <as2252258@163.com>
Date: Wed, 4 Aug 2021 14:38:20 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 Annotation/Kafka.php                          | 4 ++--
 Kafka/Kafka.php                               | 2 +-
 Kafka/{TaskProvider.php => KafkaProvider.php} | 4 ++--
 System/Abstracts/BaseApplication.php          | 4 ++--
 4 files changed, 7 insertions(+), 7 deletions(-)
 rename Kafka/{TaskProvider.php => KafkaProvider.php} (93%)

diff --git a/Annotation/Kafka.php b/Annotation/Kafka.php
index 7b85aae8..3df8933a 100644
--- a/Annotation/Kafka.php
+++ b/Annotation/Kafka.php
@@ -6,7 +6,7 @@ namespace Annotation;
 
 use Exception;
 use Kafka\ConsumerInterface;
-use Kafka\TaskProvider;
+use Kafka\KafkaProvider;
 use Snowflake\Snowflake;
 
 /**
@@ -39,7 +39,7 @@ use Snowflake\Snowflake;
             return false;
         }
 
-        /** @var TaskProvider $container */
+        /** @var KafkaProvider $container */
         $container = Snowflake::app()->get('kafka-container');
         $container->addConsumer($this->topic, [$class, 'onHandler']);
 
diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php
index aad804ce..44064fc3 100644
--- a/Kafka/Kafka.php
+++ b/Kafka/Kafka.php
@@ -127,7 +127,7 @@ class Kafka implements CustomProcess
 
                 $setting = $server->setting['worker_num'];
 
-                /** @var TaskProvider $container */
+                /** @var KafkaProvider $container */
                 $container = Snowflake::app()->get('kafka-container');
                 $handler = $container->getConsumer($topic);
 
diff --git a/Kafka/TaskProvider.php b/Kafka/KafkaProvider.php
similarity index 93%
rename from Kafka/TaskProvider.php
rename to Kafka/KafkaProvider.php
index 885f0afd..f5bb5da2 100644
--- a/Kafka/TaskProvider.php
+++ b/Kafka/KafkaProvider.php
@@ -8,10 +8,10 @@ use Snowflake\Abstracts\BaseObject;
 
 
 /**
- * Class TaskProvider
+ * Class KafkaProvider
  * @package Kafka
  */
-class TaskProvider extends BaseObject
+class KafkaProvider extends BaseObject
 {
 
 
diff --git a/System/Abstracts/BaseApplication.php b/System/Abstracts/BaseApplication.php
index 52d60a5d..70e3f362 100644
--- a/System/Abstracts/BaseApplication.php
+++ b/System/Abstracts/BaseApplication.php
@@ -23,7 +23,7 @@ use HttpServer\Server;
 use HttpServer\Shutdown;
 use JetBrains\PhpStorm\Pure;
 use Kafka\Producer;
-use Kafka\TaskProvider;
+use Kafka\KafkaProvider;
 use ReflectionException;
 use Server\ServerManager;
 use Snowflake\Aop;
@@ -520,7 +520,7 @@ abstract class BaseApplication extends Component
 			'header'            => ['class' => HttpHeaders::class],
 			'jwt'               => ['class' => Jwt::class],
 			'async'             => ['class' => Async::class],
-			'kafka-container'   => ['class' => TaskProvider::class],
+			'kafka-container'   => ['class' => KafkaProvider::class],
 			'filter'            => ['class' => HttpFilter::class],
 			'goto'              => ['class' => BaseGoto::class],
 			'response'          => ['class' => Response::class],