Files
hyperf_service/app/Amqp/Producer/Statement/FinancesProducer.php
2025-03-21 17:41:10 +08:00

28 lines
584 B
PHP

<?php
declare(strict_types=1);
namespace App\Amqp\Producer\Statement;
use Hyperf\Amqp\Annotation\Producer;
use Hyperf\Amqp\Message\ProducerMessage;
use Hyperf\Amqp\Message\Type;
#[Producer(exchange: 'Finances', routingKey: 'Finances')]
class FinancesProducer extends ProducerMessage
{
/**
* @var Type|string 消息类型
*/
protected Type|string $type = Type::DIRECT;
public function __construct($data)
{
/**
* $data string array => {"kitchen_id":"kitchen_id","cycle_id":"cycle_id"}
*/
$this->payload = $data;
}
}