video_server/app/Amqp/Producer/DemoProducer.php.close

<?php

declare(strict_types=1);

namespace App\Amqp\Producer;

use Hyperf\Amqp\Annotation\Producer;
use Hyperf\Amqp\Message\ProducerMessage;
use Hyperf\Amqp\Message\Type;

/**
 * @Producer(exchange="ex.test_noticenter", routingKey="test_app", type="topic")
 */
class DemoProducer extends ProducerMessage
{
    public function __construct($data)
    {
        $this->poolName = 'default';

        $this->type = Type::TOPIC;

        $this->payload = $data;
    }
}