src/Commands/ExecCommand.php
/**
     * Defines the behaviour of the command.
     *
     * @param InputInterface  $input  Defines inputs
     * @param OutputInterface $output Defines outputs
     */
Defines the behaviour of the command.
@param InputInterface  $input  Defines inputs
@param OutputInterface $output Defines outputs
Defines the behaviour of the command . @param InputInterface $input Defines inputs @param OutputInterface $output Defines outputs
protected function execute(InputInterface $input, OutputInterface $output)
    {
        $headers = $this->getHeaders($input);
        $body = \GuzzleHttp\json_decode($input->getOption(self::BODY), true);
        $queue = $input->getArgument(self::QUEUE);
        $queueClass = $this->queues->getClass($queue);
        $actions = Constant::getActions($queueClass . '::' . $headers['event']);
        each($actions, $this->triggerAction($headers, $body));
    }
protected function execute ( InputInterface $ input , OutputInterface $ output ) { $ headers = $ this -> getHeaders ( $ input ) ; $ body = \ GuzzleHttp \ json_decode ( $ input -> getOption ( self :: BODY ) , true ) ; $ queue = $ input -> getArgument ( self :: QUEUE ) ; $ queueClass = $ this -> queues -> getClass ( $ queue ) ; $ actions = Constant :: getActions ( $ queueClass . '::' . $ headers [ 'event' ] ) ; each ( $ actions , $ this -> triggerAction ( $ headers , $ body ) ) ; }
Defines the behaviour of the command.
Defines the behaviour of the command .