From 9d0e0d5b16dd3b8f8c686411dfe13af70db6312a Mon Sep 17 00:00:00 2001 From: Deeka Wong <8337659+huangdijia@users.noreply.github.com> Date: Sat, 12 Oct 2024 12:22:47 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=20JobConsumerManager?= =?UTF-8?q?=EF=BC=8C=E4=BF=AE=E6=94=B9=E8=BF=9B=E7=A8=8B=E5=90=8D=E7=A7=B0?= =?UTF-8?q?=E6=A0=BC=E5=BC=8F=E4=BB=A5=E5=8C=85=E5=90=AB=20'Consumer'=20?= =?UTF-8?q?=E5=89=8D=E7=BC=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/amqp-job/src/JobConsumerManager.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/amqp-job/src/JobConsumerManager.php b/src/amqp-job/src/JobConsumerManager.php index c5da8e0dd..4bd7d626e 100644 --- a/src/amqp-job/src/JobConsumerManager.php +++ b/src/amqp-job/src/JobConsumerManager.php @@ -49,7 +49,7 @@ public function run(): void $process = $this->createProcess($instance); $process->nums = $instance->getNums(); - $process->name = $class . '-' . $instance->getQueue(); + $process->name = $class . 'Consumer-' . $instance->getQueue(); ProcessManager::register($process); }