MqProducer.php 363 B

123456789101112131415161718
  1. <?php
  2. declare(strict_types=1);
  3. namespace App\Amqp\Producer;
  4. use Hyperf\Amqp\Annotation\Producer;
  5. use Hyperf\Amqp\Message\ProducerMessage;
  6. #[Producer(exchange: 'hyperf', routingKey: 'hyperf')]
  7. class MqProducer extends ProducerMessage
  8. {
  9. public function __construct($data)
  10. {
  11. // $this->poolName = 'default';
  12. $this->payload = $data;
  13. }
  14. }