Symfonyで外部のプログラムを実行する

    protected
        $outputBuffer = '';

    protected function execute($arguments = array(), $options = array())
    {
        // initialize the database connection
        $databaseManager = new sfDatabaseManager($this->configuration);
        $connection = $databaseManager->getDatabase($options['connection'] ? $options['connection'] : null)->getConnection();

        // 処理待ちリストから一行取得
        $process = Doctrine::getTable('Processes')->findOneByStatus('WAIT');
        $command = $process['command'];

        // バッファクリア
        $this->outputBuffer = '';
        try {
            // 実行。第二引数は標準出力、第三引数は標準エラー出力を受け取るコールバック関数
            list($output, $err) = $this->getFilesystem()->execute($command, array($this, 'setBuffer'), array($this, 'setBuffer'));
            $process['status'] = 'SUCCESS';
            $process['message'] = $output;
            $process->save();
        } catch (RuntimeException $e) {
            // コマンドが実行できなかった場合と、終了時エラーの場合はRuntimeExceptionがthrowされる
            $process['status'] = 'FAILED';
            // エラー時はexecuteの戻り値を取得できないのでコールバックの結果からメッセージを取得
            $process['message'] = $this->outputBuffer;
            // 必要なら$e->getCode();でエラーコード取得できます
            $process->save();
        }
    }

    public function setBuffer($output)
    {
        $this->outputBuffer .= $output;
    }