mmucklo / DtcQueueBundle

        }

        // Just save a new job

        if (!$job->getId() && $objectManager instanceof EntityManager) {

            if (null !== self::$resetInsertCalled && spl_object_hash($objectManager) === self::$resetInsertCalled) {

                // Insert SQL is cached...

                throw new \Exception("Can't call save and reset within the same process cycle");

            }

            self::$saveInsertCalled = spl_object_hash($objectManager);

        }

        $objectManager->persist($job);

        $objectManager->flush();

        $offset)

    {

        $objectManager = $this->getObjectManager();

        if ($objectManager instanceof EntityManager) {

            if (null !== self::$saveInsertCalled && spl_object_hash($objectManager) === self::$saveInsertCalled) {

                // Insert SQL is cached...

                throw new \Exception("Can't call reset and save within the same process cycle");

            }

            self::$resetInsertCalled = spl_object_hash($objectManager);

        }

        $objectName = $this->getObjectName();

        $archiveObjectName = $this->getArchiveObjectName();