kiri-core/Annotation/Rpc/Consumer.php

<?php


namespace Annotation\Rpc;


use Annotation\Attribute;
use Exception;
use Snowflake\Snowflake;


/**
 * Class Consumer
 * @package Annotation\Rpc
 */
#[\Attribute(\Attribute::TARGET_METHOD)] class Consumer extends Attribute
{


	/**
	 * Consumer constructor.
	 * @param string $cmd
	 */
	public function __construct(public string $cmd)
	{

	}


	/**
	 * @param mixed $class
	 * @param mixed $method
	 * @return bool
	 * @throws Exception
	 */
    public function execute(mixed $class, mixed $method = ''): bool
    {
		$rpc = Snowflake::app()->getRpc();
		$rpc->addConsumer($this->cmd, [$class, $method]);
		return true; // TODO: Change the autogenerated stub
	}


}