Connector/Console/Command/BacklogProcessCommand.php
protected function execute(InputInterface $input, OutputInterface $output)
    {
        if (method_exists($this->logger, 'pushHandler')) {
            $this->logger->pushHandler(new ConsoleHandler($output));
        }

        $amount = (int) $input->getArgument('amount');

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

        try {
            $counter = 0;

            while ($counter < $amount && $command = $this->backlogService->dequeue()) {
                ++$counter;

                $this->serviceBus->handle($command);
                $this->outputHandler->advanceProgressBar();
            }
        } catch (Exception $exception) {
            $this->logger->error($exception->getMessage());
        } catch (Throwable $exception) {
            $this->logger->error($exception->getMessage());
        }

        $this->outputHandler->finishProgressBar();
    }
protected function execute(InputInterface $input, OutputInterface $output)
    {
        if (method_exists($this->logger, 'pushHandler')) {
            $this->logger->pushHandler(new ConsoleHandler($output));
        }

        $amount = (int) $input->getArgument('amount');

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

        try {
            $counter = 0;

            while ($counter < $amount && $command = $this->backlogService->dequeue()) {
                ++$counter;

                $this->serviceBus->handle($command);
                $this->outputHandler->advanceProgressBar();
            }
        } catch (Exception $exception) {
            $this->logger->error($exception->getMessage());
        } catch (Throwable $exception) {
            $this->logger->error($exception->getMessage());
        }

        $this->outputHandler->finishProgressBar();
    }
protected function execute ( InputInterface $ input , OutputInterface $ output ) { if ( method_exists ( $ this -> logger , 'pushHandler' ) ) { $ this -> logger -> pushHandler ( new ConsoleHandler ( $ output ) ) ; } $ amount = ( int ) $ input -> getArgument ( 'amount' ) ; $ this -> outputHandler -> initialize ( $ input , $ output ) ; $ this -> outputHandler -> startProgressBar ( $ amount ) ; try { $ counter = 0 ; while ( $ counter < $ amount && $ command = $ this -> backlogService -> dequeue ( ) ) { ++ $ counter ; $ this -> serviceBus -> handle ( $ command ) ; $ this -> outputHandler -> advanceProgressBar ( ) ; } } catch ( Exception $ exception ) { $ this -> logger -> error ( $ exception -> getMessage ( ) ) ; } catch ( Throwable $ exception ) { $ this -> logger -> error ( $ exception -> getMessage ( ) ) ; } $ this -> outputHandler -> finishProgressBar ( ) ; }
{@inheritdoc}
{