Core/src/Batch/SysvProcessor.php
public function submit($item, $idNum)
    {
        if (!array_key_exists($idNum, $this->sysvQs)) {
            $this->sysvQs[$idNum] =
                msg_get_queue($this->getSysvKey($idNum));
        }
        $result = @msg_send(
            $this->sysvQs[$idNum],
            self::$typeDirect,
            $item
        );
        if ($result === false) {
            // Try to put the content in a temp file and send the filename.
            $tempFile = tempnam(sys_get_temp_dir(), 'Item');
            $result = file_put_contents($tempFile, serialize($item));
            if ($result === false) {
                throw new \RuntimeException(
                    "Failed to write to $tempFile while submiting the item"
                );
            }
            $result = @msg_send(
                $this->sysvQs[$idNum],
                self::$typeFile,
                $tempFile
            );
            if ($result === false) {
                @unlink($tempFile);
                throw new \RuntimeException(
                    "Failed to submit the filename: $tempFile"
                );
            }
        }
    }
public function submit($item, $idNum)
    {
        if (!array_key_exists($idNum, $this->sysvQs)) {
            $this->sysvQs[$idNum] =
                msg_get_queue($this->getSysvKey($idNum));
        }
        $result = @msg_send(
            $this->sysvQs[$idNum],
            self::$typeDirect,
            $item
        );
        if ($result === false) {
            // Try to put the content in a temp file and send the filename.
            $tempFile = tempnam(sys_get_temp_dir(), 'Item');
            $result = file_put_contents($tempFile, serialize($item));
            if ($result === false) {
                throw new \RuntimeException(
                    "Failed to write to $tempFile while submiting the item"
                );
            }
            $result = @msg_send(
                $this->sysvQs[$idNum],
                self::$typeFile,
                $tempFile
            );
            if ($result === false) {
                @unlink($tempFile);
                throw new \RuntimeException(
                    "Failed to submit the filename: $tempFile"
                );
            }
        }
    }
public function submit ( $ item , $ idNum ) { if ( ! array_key_exists ( $ idNum , $ this -> sysvQs ) ) { $ this -> sysvQs [ $ idNum ] = msg_get_queue ( $ this -> getSysvKey ( $ idNum ) ) ; } $ result = @ msg_send ( $ this -> sysvQs [ $ idNum ] , self :: $ typeDirect , $ item ) ; if ( $ result === false ) { // Try to put the content in a temp file and send the filename. $ tempFile = tempnam ( sys_get_temp_dir ( ) , 'Item' ) ; $ result = file_put_contents ( $ tempFile , serialize ( $ item ) ) ; if ( $ result === false ) { throw new \ RuntimeException ( "Failed to write to $tempFile while submiting the item" ) ; } $ result = @ msg_send ( $ this -> sysvQs [ $ idNum ] , self :: $ typeFile , $ tempFile ) ; if ( $ result === false ) { @ unlink ( $ tempFile ) ; throw new \ RuntimeException ( "Failed to submit the filename: $tempFile" ) ; } } }
Submit an item for async processing.

@param mixed $item An item to submit.
@param int $idNum A numeric id of the job.
@return void

@throws \RuntimeException when failed to store the item.
Submit an item for async processing .