消费者

common/components/rabbitmq/commonConsumer.php

@@ -6,7 +6,7 @@
  * Time: 14:54
  */
 
-namespace common\components\rabbitmq\consumer;
+namespace common\components\rabbitmq;
 
 use mikemadisonweb\rabbitmq\components\ConsumerInterface;
 use PhpAmqpLib\Message\AMQPMessage;

common/components/rabbitmq/customConsumer.php

@@ -4,7 +4,7 @@
  * 处理客户创建、修改等业务操作
  */
 
-namespace common\components\rabbitmq\consumer;
+namespace common\components\rabbitmq;
 
 use mikemadisonweb\rabbitmq\components\ConsumerInterface;
 use PhpAmqpLib\Message\AMQPMessage;

common/components/rabbitmq/importDataConsumer.php

@@ -6,7 +6,7 @@
  * Time: 14:54
  */
 
-namespace common\components\rabbitmq\consumer;
+namespace common\components\rabbitmq;
 
 use mikemadisonweb\rabbitmq\components\ConsumerInterface;
 use PhpAmqpLib\Message\AMQPMessage;

common/components/rabbitmq/informConsumer.php

@@ -6,7 +6,7 @@
  * Time: 14:54
  */
 
-namespace common\components\rabbitmq\consumer;
+namespace common\components\rabbitmq;
 
 use bizHd\message\services\InformAdminService;
 use bizHd\message\services\InformUserService;

common/components/rabbitmq/notifyConsumer.php

@@ -4,7 +4,7 @@
  * 处理各种消息通知：新订单、新客户、充值、销账、配送状态变更等
  */
 
-namespace common\components\rabbitmq\consumer;
+namespace common\components\rabbitmq;
 
 use common\components\noticeUtil;
 use mikemadisonweb\rabbitmq\components\ConsumerInterface;

common/components/rabbitmq/openShopInitConsumer.php

@@ -6,7 +6,7 @@
  * Time: 14:54
  */
 
-namespace common\components\rabbitmq\consumer;
+namespace common\components\rabbitmq;
 
 
 use biz\sj\services\MerchantService;

common/components/rabbitmq/printMsgConsumer.php

@@ -6,7 +6,7 @@
  * Time: 14:54
  */
 
-namespace common\components\rabbitmq\consumer;
+namespace common\components\rabbitmq;
 
 use mikemadisonweb\rabbitmq\components\ConsumerInterface;
 use PhpAmqpLib\Message\AMQPMessage;

common/components/rabbitmq/stockConsumer.php

@@ -4,7 +4,7 @@
  * 处理花材库存补充、扣减等库存操作
  */
 
-namespace common\components\rabbitmq\consumer;
+namespace common\components\rabbitmq;
 
 use mikemadisonweb\rabbitmq\components\ConsumerInterface;
 use PhpAmqpLib\Message\AMQPMessage;

common/config/rabbitMQ.php

@@ -113,27 +113,27 @@ $rabbitMQ = [
             //客户操作消费者
             'name' => 'customConsumer',
             'callbacks' => [
-                'customQueue' => '\common\components\rabbitmq\consumer\customConsumer',
+                'customQueue' => '\common\components\rabbitmq\customConsumer',
             ]
         ],
         [
             //库存管理消费者
             'name' => 'stockConsumer',
             'callbacks' => [
-                'stockQueue' => '\common\components\rabbitmq\consumer\stockConsumer',
+                'stockQueue' => '\common\components\rabbitmq\stockConsumer',
             ]
         ],
         [
             //通知消费者
             'name' => 'notifyConsumer',
             'callbacks' => [
-                'notifyQueue' => '\common\components\rabbitmq\consumer\notifyConsumer',
+                'notifyQueue' => '\common\components\rabbitmq\notifyConsumer',
             ]
         ],
         [
             'name' => 'importDataConsumer',
             'callbacks' => [
-                'queues1' => '\common\components\rabbitmq\consumer\importDataConsumer',
+                'queues1' => '\common\components\rabbitmq\importDataConsumer',
             ],
         ]
     ],