Connector/Console/Command/ProcessCommand.php
protected function execute(InputInterface $input, OutputInterface $output)
    {
        $all = (bool) $input->getOption('all');

        if ((bool) $input->getOption('disableBacklog')) {
            BacklogCommandHandlerMiddleware::$active = false;
        }

        $objectType = $input->getArgument('objectType');
        $objectIdentifier = $input->getArgument('objectIdentifier');

        if (method_exists($this->logger, 'pushHandler')) {
            $this->logger->pushHandler(new ConsoleHandler($output));
        }

        $this->outputHandler->initialize($input, $output);

        try {
            if ($objectIdentifier) {
                $queryType = QueryType::ONE;

                BacklogCommandHandlerMiddleware::$active = false;
            } else {
                $queryType = $all ? QueryType::ALL : QueryType::CHANGED;
            }

            $this->connector->handle($queryType, $objectType, $objectIdentifier);
        } catch (Exception $exception) {
            $this->logger->error($exception->getMessage());
        } catch (Throwable $exception) {
            $this->logger->error($exception->getMessage());
        }
    }
protected function execute(InputInterface $input, OutputInterface $output)
    {
        $all = (bool) $input->getOption('all');

        if ((bool) $input->getOption('disableBacklog')) {
            BacklogCommandHandlerMiddleware::$active = false;
        }

        $objectType = $input->getArgument('objectType');
        $objectIdentifier = $input->getArgument('objectIdentifier');

        if (method_exists($this->logger, 'pushHandler')) {
            $this->logger->pushHandler(new ConsoleHandler($output));
        }

        $this->outputHandler->initialize($input, $output);

        try {
            if ($objectIdentifier) {
                $queryType = QueryType::ONE;

                BacklogCommandHandlerMiddleware::$active = false;
            } else {
                $queryType = $all ? QueryType::ALL : QueryType::CHANGED;
            }

            $this->connector->handle($queryType, $objectType, $objectIdentifier);
        } catch (Exception $exception) {
            $this->logger->error($exception->getMessage());
        } catch (Throwable $exception) {
            $this->logger->error($exception->getMessage());
        }
    }
protected function execute ( InputInterface $ input , OutputInterface $ output ) { $ all = ( bool ) $ input -> getOption ( 'all' ) ; if ( ( bool ) $ input -> getOption ( 'disableBacklog' ) ) { BacklogCommandHandlerMiddleware :: $ active = false ; } $ objectType = $ input -> getArgument ( 'objectType' ) ; $ objectIdentifier = $ input -> getArgument ( 'objectIdentifier' ) ; if ( method_exists ( $ this -> logger , 'pushHandler' ) ) { $ this -> logger -> pushHandler ( new ConsoleHandler ( $ output ) ) ; } $ this -> outputHandler -> initialize ( $ input , $ output ) ; try { if ( $ objectIdentifier ) { $ queryType = QueryType :: ONE ; BacklogCommandHandlerMiddleware :: $ active = false ; } else { $ queryType = $ all ? QueryType :: ALL : QueryType :: CHANGED ; } $ this -> connector -> handle ( $ queryType , $ objectType , $ objectIdentifier ) ; } catch ( Exception $ exception ) { $ this -> logger -> error ( $ exception -> getMessage ( ) ) ; } catch ( Throwable $ exception ) { $ this -> logger -> error ( $ exception -> getMessage ( ) ) ; } }
{@inheritdoc}
{