mq

app/Amqp/Consumer/MqConsumer.php

@@ -13,7 +13,7 @@ use PhpAmqpLib\Message\AMQPMessage;
 use Psr\Log\LoggerInterface;
 use Hyperf\Redis\RedisFactory;
 
-#[Consumer(exchange: 'hyperf', routingKey: 'hyperf', queue: 'hyperf', name: "MqConsumer", nums: 1)]
+#[Consumer(exchange: 'chatdev', routingKey: 'chatdev', queue: 'chatdev', name: "chatdev", nums: 1)]
 class MqConsumer extends ConsumerMessage
 {
     /**

app/Amqp/Producer/MqProducer.php

@@ -7,7 +7,7 @@ namespace App\Amqp\Producer;
 use Hyperf\Amqp\Annotation\Producer;
 use Hyperf\Amqp\Message\ProducerMessage;
 
-#[Producer(exchange: 'hyperf', routingKey: 'hyperf')]
+#[Producer(exchange: 'chatdev', routingKey: 'chatdev')]
 class MqProducer extends ProducerMessage
 {
     public function __construct($data)