Subscriber/CronjobSubscriber.php
public function onRunCronjobProcessBacklog(Args $args)
    {
        try {
            $counter = 0;
            while ($counter < 200 && $command = $this->backlogService->dequeue()) {
                ++$counter;

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

        $args->setReturn(true);

        return true;
    }
public function onRunCronjobProcessBacklog(Args $args)
    {
        try {
            $counter = 0;
            while ($counter < 200 && $command = $this->backlogService->dequeue()) {
                ++$counter;

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

        $args->setReturn(true);

        return true;
    }
public function onRunCronjobProcessBacklog ( Args $ args ) { try { $ counter = 0 ; while ( $ counter < 200 && $ command = $ this -> backlogService -> dequeue ( ) ) { ++ $ counter ; $ this -> serviceBus -> handle ( $ command ) ; } } catch ( Exception $ exception ) { $ this -> logger -> error ( $ exception -> getMessage ( ) ) ; } catch ( Throwable $ exception ) { $ this -> logger -> error ( $ exception -> getMessage ( ) ) ; } $ args -> setReturn ( true ) ; return true ; }
@param Args $args

@return bool
@param Args $args