public function execute(array $arguments): void
    {
        if (!isset($arguments['job'])) {
            throw new UnrecoverableJobException('Missing doctrine delay job');
        }

        $job = $arguments['job'];
        if (!$job instanceof DoctrineDelayJob) {
            throw new UnrecoverableJobException('Invalid job');
        }

        $this->queueManagerRegistry->put($job->getName(), $job->getArguments(), $job->getOptions(), $job->getManager());
    }
public function execute(array $arguments): void
    {
        if (!isset($arguments['job'])) {
            throw new UnrecoverableJobException('Missing doctrine delay job');
        }

        $job = $arguments['job'];
        if (!$job instanceof DoctrineDelayJob) {
            throw new UnrecoverableJobException('Invalid job');
        }

        $this->queueManagerRegistry->put($job->getName(), $job->getArguments(), $job->getOptions(), $job->getManager());
    }
public function execute ( array $ arguments ) : void { if ( ! isset ( $ arguments [ 'job' ] ) ) { throw new UnrecoverableJobException ( 'Missing doctrine delay job' ) ; } $ job = $ arguments [ 'job' ] ; if ( ! $ job instanceof DoctrineDelayJob ) { throw new UnrecoverableJobException ( 'Invalid job' ) ; } $ this -> queueManagerRegistry -> put ( $ job -> getName ( ) , $ job -> getArguments ( ) , $ job -> getOptions ( ) , $ job -> getManager ( ) ) ; }
Called to start the queued task.

@throws \Exception
@throws UnrecoverableJobException
Called to start the queued task .