src/Task.php
public static function deliverByProcess(
        string $taskName,
        string $methodName,
        array $params = [],
        int $timeout = 3,
        int $workerId = 0,
        string $type = self::TYPE_ASYNC
    ): bool {
        /* @var PipeMessageInterface $pipeMessage */
        $pipeMessage = bean(PipeMessage::class);
        $message = $pipeMessage->pack(PipeMessage::MESSAGE_TYPE_TASK, [
            'name' => $taskName,
            'method' => $methodName,
            'params' => $params,
            'timeout' => $timeout,
            'type' => $type,
        ]);
        return App::$server->getServer()->sendMessage($message, $workerId);
    }
public static function deliverByProcess(
        string $taskName,
        string $methodName,
        array $params = [],
        int $timeout = 3,
        int $workerId = 0,
        string $type = self::TYPE_ASYNC
    ): bool {
        /* @var PipeMessageInterface $pipeMessage */
        $pipeMessage = bean(PipeMessage::class);
        $message = $pipeMessage->pack(PipeMessage::MESSAGE_TYPE_TASK, [
            'name' => $taskName,
            'method' => $methodName,
            'params' => $params,
            'timeout' => $timeout,
            'type' => $type,
        ]);
        return App::$server->getServer()->sendMessage($message, $workerId);
    }
public static function deliverByProcess ( string $ taskName , string $ methodName , array $ params = [ ] , int $ timeout = 3 , int $ workerId = 0 , string $ type = self :: TYPE_ASYNC ) : bool { /* @var PipeMessageInterface $pipeMessage */ $ pipeMessage = bean ( PipeMessage :: class ) ; $ message = $ pipeMessage -> pack ( PipeMessage :: MESSAGE_TYPE_TASK , [ 'name' => $ taskName , 'method' => $ methodName , 'params' => $ params , 'timeout' => $ timeout , 'type' => $ type , ] ) ; return App :: $ server -> getServer ( ) -> sendMessage ( $ message , $ workerId ) ; }
Deliver task by process
Deliver task by process