identifierToId) ? $this->jobs[$identifier] : null; } /** * Get the job with the given numeric id. * * @param int $idNum A numeric id of the job. * * @return JobInterface|null */ public function getJobFromIdNum($idNum) { return array_key_exists($idNum, $this->idToIdentifier) ? $this->jobs[$this->idToIdentifier[$idNum]] : null; } /** * Register a job for executing in batch. * * @param string $identifier Unique identifier of the job. * @param callable $callback Callback that accepts the job $idNum * and returns a JobInterface instance. * @return void */ public function registerJob($identifier, $callback) { if (array_key_exists($identifier, $this->identifierToId)) { $idNum = $this->identifierToId[$identifier]; } else { $idNum = count($this->identifierToId) + 1; $this->idToIdentifier[$idNum] = $identifier; } $this->jobs[$identifier] = call_user_func($callback, $idNum); $this->identifierToId[$identifier] = $idNum; } /** * Get all the jobs indexed by the job's identifier. * * @return array Associative array of JobInterface instances keyed by a * string identifier. */ public function getJobs() { return $this->jobs; } }