mmucklo / DtcQueueBundle

    {

        $this->run->setLastHeartbeatAt(new \DateTime());

        $this->run->setElapsed(microtime(true) - $start);

        if ($this->runManager instanceof BaseRunManager) {

            $objectManager = $this->runManager->getObjectManager();

            $objectManager->persist($this->run);

            $objectManager->flush();

        }

    }

    /**

    protected function updateProcessed($count)

    {

        $this->run->setProcessed($count);

        if ($this->runManager instanceof BaseRunManager) {

            $objectManager = $this->runManager->getObjectManager();

            $objectManager->persist($this->run);

            $objectManager->flush();

        }

    }

    /**

        $this->run->setHostname(gethostname());

        $this->run->setPid(getmypid());

        $this->run->setProcessed(0);

        if ($this->runManager instanceof BaseRunManager) {

            $objectManager = $this->runManager->getObjectManager();

            $objectManager->persist($this->run);

            $objectManager->flush();

        }

    }

    /**

            $this->run->setEndedAt($endedTime);

        }

        $this->run->setElapsed($end - $start);

        if ($this->runManager instanceof BaseRunManager) {

            $objectManager = $this->runManager->getObjectManager();

            $objectManager->remove($this->run);

            $objectManager->flush();

        }

        $this->log('info', 'Ended with '.$this->run->getProcessed().' job(s) processed over '.strval($this->run->getElapsed()).' seconds.');

    }