lamoda / queue-bundle

        try {

            $republishedQueueIds = [];

            do {

                $queues = $this->queueService->getToRepublish($batchSize);

                if ($queues) {

                    foreach ($queues as $queue) {

                        $this->publisherFactory->republish($queue);

                        $this->queueService->flush($queue);

                        $republishedQueueIds[] = $queue->getId();

                    }

                }

                $this->queueService->commit();

                $this->publisherFactory->releaseAll();

            } while (count($queues) === $batchSize);

            if ($republishedQueueIds) {

                $this->logger->info(

        $this->queueService->beginTransaction();

        try {

            do {

                $queues = $this->queueService->getToRestore($batchSize);

                if ($queues) {

                    foreach ($queues as $queue) {

                        $this->publisherFactory->requeue($queue);

                        $this->queueService->flush($queue);

                    }

                }

                $this->queueService->commit();

                $this->publisherFactory->releaseAll();

            } while (count($queues) === $batchSize);

        } catch (Throwable $exception) {

            $this->queueService->rollback();